mirror of
https://github.com/spacebarchat/server.git
synced 2026-09-16 10:42:39 +00:00
✨ Util
This commit is contained in:
@@ -1,9 +0,0 @@
|
||||
import { r } from "rethinkdb-ts";
|
||||
|
||||
async function main() {
|
||||
const connection = await r.connect({ port: 28015, host: "192.168.178.122" });
|
||||
|
||||
r.db("test");
|
||||
}
|
||||
|
||||
main();
|
||||
@@ -0,0 +1,37 @@
|
||||
const jwa = require("jwa");
|
||||
|
||||
var STR64 = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-_".split("");
|
||||
|
||||
function base64url(string: string, encoding: string) {
|
||||
// @ts-ignore
|
||||
return Buffer.from(string, encoding).toString("base64").replace(/=/g, "").replace(/\+/g, "-").replace(/\//g, "_");
|
||||
}
|
||||
|
||||
function to64String(input: number, current = ""): string {
|
||||
if (input < 0 && current.length == 0) {
|
||||
input = input * -1;
|
||||
}
|
||||
var modify = input % 64;
|
||||
var remain = Math.floor(input / 64);
|
||||
var result = STR64[modify] + current;
|
||||
return remain <= 0 ? result : to64String(remain, result);
|
||||
}
|
||||
|
||||
function to64Parse(input: string) {
|
||||
var result = 0;
|
||||
var toProc = input.split("");
|
||||
var e;
|
||||
for (e in toProc) {
|
||||
result = result * 64 + STR64.indexOf(toProc[e]);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
// @ts-ignore
|
||||
const start = `${base64url("311129357362135041")}.${to64String(Date.now())}`;
|
||||
const signature = jwa("HS256").sign(start, `test`);
|
||||
const token = `${start}.${signature}`;
|
||||
console.log(token);
|
||||
|
||||
// MzExMTI5MzU3MzYyMTM1MDQx.XdQb_rA.907VgF60kocnOTl32MSUWGSSzbAytQ0jbt36KjLaxuY
|
||||
// MzExMTI5MzU3MzYyMTM1MDQx.XdQbaPy.4vGx4L7IuFJGsRe6IL3BeybLIvbx4Vauvx12pwNsy2U
|
||||
@@ -0,0 +1,8 @@
|
||||
import jwt from "jsonwebtoken";
|
||||
|
||||
// console.log(jwt.sign("test", "test"));
|
||||
|
||||
jwt.verify(`${"2WmFS_EAdYFCBOFM9pVPo9g4bpuI2I9U_JGTCfrx7Tk".repeat(1000000)}`, "test", (err, decoded) => {
|
||||
if (err) console.error(err);
|
||||
console.log(decoded);
|
||||
});
|
||||
@@ -0,0 +1,14 @@
|
||||
import mongoose from "mongoose";
|
||||
|
||||
async function main() {
|
||||
const mongoConnection = await mongoose.createConnection(
|
||||
"mongodb://localhost:27017/lambert?readPreference=secondaryPreferred",
|
||||
{
|
||||
useNewUrlParser: true,
|
||||
useUnifiedTopology: false,
|
||||
}
|
||||
);
|
||||
console.log("connected");
|
||||
}
|
||||
|
||||
main();
|
||||
@@ -0,0 +1,34 @@
|
||||
import { r } from "rethinkdb-ts";
|
||||
|
||||
async function main() {
|
||||
const connection = await r.connect({ port: 28015 });
|
||||
|
||||
const db = r.db("test");
|
||||
const cursor = await db
|
||||
.table("guilds")
|
||||
.get(0)
|
||||
.changes({ squash: true })
|
||||
.map(function (row) {
|
||||
return row("old_val")
|
||||
.keys()
|
||||
.setUnion(row("new_val").keys())
|
||||
.concatMap(function (key) {
|
||||
return r.branch(
|
||||
row("old_val")(key).ne(row("new_val")(key)).default(true),
|
||||
[[key, row("new_val")(key).default(null)]],
|
||||
[]
|
||||
);
|
||||
})
|
||||
.coerceTo("object");
|
||||
})
|
||||
.run(connection);
|
||||
|
||||
console.log("each");
|
||||
cursor.each(function (err, row) {
|
||||
if (err) throw err;
|
||||
console.log(row);
|
||||
});
|
||||
console.log("eachend");
|
||||
}
|
||||
|
||||
main();
|
||||
Reference in New Issue
Block a user