Compare commits

...

23 commits

Author SHA1 Message Date
ab816d8cb6
Some progress towards accepting and rejecting follows (#3)
Reviewed-on: #3
2024-10-23 05:47:17 +00:00
569c4fbf32
think i'm dropping this here for now 2024-10-23 06:01:52 +02:00
0f68d3ad14
Move nodeinfo to its own file 2024-10-23 03:50:34 +02:00
548cfe139b
Remove comment about message queues 2024-10-23 03:47:37 +02:00
0df82ac931
Setup Postgres-based message queue 2024-10-23 03:44:20 +02:00
b29211c387
Sort of following now 2024-10-22 11:11:52 +02:00
5f61961792
Commit, but this is broken on akkoma auth fetch 2024-10-22 10:29:25 +02:00
7d3ab00c2a
Various things 2024-10-22 05:19:31 +02:00
58d4e3b8a4
Authorized fetch, anyone? 2024-10-21 06:30:45 +02:00
92d543dbbd
Keys seem to be working!
This is wild though: https://fosstodon.org/@hongminhee/113343168981354525
2024-10-21 06:20:41 +02:00
e2f2b3702b
Permissions are too hard, idc 2024-10-21 04:00:59 +02:00
4cb2e53ace
Various changes to get the server to launch again 2024-10-21 03:47:04 +02:00
f490404fb6
Create database initialization scripts 2024-10-21 03:24:20 +02:00
c554cb5936
Create VSCode launch configs 2024-10-21 03:24:07 +02:00
4ebacf6753
Fix logger name 2024-10-20 19:23:01 +02:00
2f54d41625
Incomplete progress, transition toward postgres 2024-10-20 07:48:27 +02:00
292d3d3e7d
Setup follow handler and actor mapper 2024-10-20 06:58:51 +02:00
1c4ca235b3
Fedify → federation handlers 2024-10-20 06:58:32 +02:00
fca9d4eb7f
Add typing to ctx 2024-10-20 06:25:51 +02:00
b22139ea73
Rename actor dispatcher to actor handler 2024-10-20 06:25:20 +02:00
42c7f73bf5
Serve a favicon 2024-10-20 06:22:27 +02:00
7ce86f3036
Refactor all existing code 2024-10-20 06:13:09 +02:00
325a8ad9ad
Rename graphql_test to graphql_stratz_test 2024-10-20 04:39:40 +02:00
35 changed files with 1227 additions and 324 deletions

40
.vscode/launch.json vendored Normal file
View file

@ -0,0 +1,40 @@
{
// Use IntelliSense to learn about possible attributes.
// Hover to view descriptions of existing attributes.
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
"version": "0.2.0",
"configurations": [
{
"request": "launch",
"name": "Reinitialize database",
"type": "node",
"runtimeExecutable": "/usr/bin/deno",
"runtimeArgs": [
"run",
"--no-prompt",
"--allow-all",
"--inspect-wait"
],
"program": "${workspaceFolder}/src/entry/dbInit.ts",
"cwd": "${workspaceFolder}",
"envFile": "${workspaceFolder}/local.env",
"attachSimplePort": 9229
},
{
"request": "launch",
"name": "Dev Server",
"type": "node",
"runtimeExecutable": "/usr/bin/deno",
"runtimeArgs": [
"run",
"--no-prompt",
"--allow-all",
"--inspect-wait"
],
"program": "${workspaceFolder}/src/entry/server.ts",
"cwd": "${workspaceFolder}",
"envFile": "${workspaceFolder}/local.env",
"attachSimplePort": 9229
}
]
}

View file

@ -1,13 +1,14 @@
{ {
"imports": { "imports": {
"@@npm/ioredis": "npm:ioredis@^5.4.1", "@@npm/ioredis": "npm:ioredis@^5.4.1",
"@@x/escape": "https://deno.land/x/escape@1.3.0/mod.ts",
"@fedify/fedify": "jsr:@fedify/fedify@^1.0.2", "@fedify/fedify": "jsr:@fedify/fedify@^1.0.2",
"@fedify/redis": "jsr:@fedify/redis@^0.3.0", "@fedify/postgres": "jsr:@fedify/postgres@^0.1.0",
"@hongminhee/x-forwarded-fetch": "jsr:@hongminhee/x-forwarded-fetch@^0.2.0", "@hongminhee/x-forwarded-fetch": "jsr:@hongminhee/x-forwarded-fetch@^0.2.0",
"@logtape/logtape": "jsr:@logtape/logtape@^0.6.3", "@logtape/logtape": "jsr:@logtape/logtape@^0.6.3",
"@opentelemetry/api": "npm:@opentelemetry/api@^1.9.0", "@opentelemetry/api": "npm:@opentelemetry/api@^1.9.0",
"@std/assert": "jsr:@std/assert@1", "@std/assert": "jsr:@std/assert@1",
"@@x/escape": "https://deno.land/x/escape@1.3.0/mod.ts" "@@npm/postgres": "npm:postgres@^3.4.4"
}, },
"unstable": [ "unstable": [
"temporal" "temporal"

127
deno.lock
View file

@ -4,7 +4,7 @@
"specifiers": { "specifiers": {
"jsr:@fedify/fedify@^1.0.0": "jsr:@fedify/fedify@1.0.2", "jsr:@fedify/fedify@^1.0.0": "jsr:@fedify/fedify@1.0.2",
"jsr:@fedify/fedify@^1.0.2": "jsr:@fedify/fedify@1.0.2", "jsr:@fedify/fedify@^1.0.2": "jsr:@fedify/fedify@1.0.2",
"jsr:@fedify/redis@^0.3.0": "jsr:@fedify/redis@0.3.0", "jsr:@fedify/postgres@^0.1.0": "jsr:@fedify/postgres@0.1.0",
"jsr:@hongminhee/x-forwarded-fetch@^0.2.0": "jsr:@hongminhee/x-forwarded-fetch@0.2.0", "jsr:@hongminhee/x-forwarded-fetch@^0.2.0": "jsr:@hongminhee/x-forwarded-fetch@0.2.0",
"jsr:@hugoalh/http-header-link@^1.0.2": "jsr:@hugoalh/http-header-link@1.0.2", "jsr:@hugoalh/http-header-link@^1.0.2": "jsr:@hugoalh/http-header-link@1.0.2",
"jsr:@hugoalh/is-string-singleline@1.0.2": "jsr:@hugoalh/is-string-singleline@1.0.2", "jsr:@hugoalh/is-string-singleline@1.0.2": "jsr:@hugoalh/is-string-singleline@1.0.2",
@ -20,12 +20,14 @@
"npm:@phensley/language-tag@^1.9.0": "npm:@phensley/language-tag@1.9.0", "npm:@phensley/language-tag@^1.9.0": "npm:@phensley/language-tag@1.9.0",
"npm:@types/node": "npm:@types/node@18.16.19", "npm:@types/node": "npm:@types/node@18.16.19",
"npm:asn1js@^3.0.5": "npm:asn1js@3.0.5", "npm:asn1js@^3.0.5": "npm:asn1js@3.0.5",
"npm:graffle@next": "npm:graffle@8.0.0-next.68_@opentelemetry+api@1.9.0_graphql@16.9.0",
"npm:ioredis@^5.4.1": "npm:ioredis@5.4.1", "npm:ioredis@^5.4.1": "npm:ioredis@5.4.1",
"npm:json-canon@^1.0.1": "npm:json-canon@1.0.1", "npm:json-canon@^1.0.1": "npm:json-canon@1.0.1",
"npm:jsonld@^8.3.2": "npm:jsonld@8.3.2", "npm:jsonld@^8.3.2": "npm:jsonld@8.3.2",
"npm:multibase@^4.0.6": "npm:multibase@4.0.6", "npm:multibase@^4.0.6": "npm:multibase@4.0.6",
"npm:multicodec@^3.2.1": "npm:multicodec@3.2.1", "npm:multicodec@^3.2.1": "npm:multicodec@3.2.1",
"npm:pkijs@^3.2.4": "npm:pkijs@3.2.4", "npm:pkijs@^3.2.4": "npm:pkijs@3.2.4",
"npm:postgres@^3.4.4": "npm:postgres@3.4.4",
"npm:uri-template-router@^0.0.16": "npm:uri-template-router@0.0.16", "npm:uri-template-router@^0.0.16": "npm:uri-template-router@0.0.16",
"npm:url-template@^3.1.1": "npm:url-template@3.1.1" "npm:url-template@^3.1.1": "npm:url-template@3.1.1"
}, },
@ -50,12 +52,11 @@
"npm:url-template@^3.1.1" "npm:url-template@^3.1.1"
] ]
}, },
"@fedify/redis@0.3.0": { "@fedify/postgres@0.1.0": {
"integrity": "48068af7ad24d4f6c6935d6f869659faeb92281a9e796921f9ba7d94e74f8cfc", "integrity": "350e3e535372d84acebe7392ae98495e388f30d75165d52c6d32a8dc6e940b80",
"dependencies": [ "dependencies": [
"jsr:@fedify/fedify@^1.0.0", "jsr:@fedify/fedify@^1.0.0",
"jsr:@logtape/logtape@^0.6.3", "npm:postgres@^3.4.4"
"npm:ioredis@^5.4.1"
] ]
}, },
"@hongminhee/x-forwarded-fetch@0.2.0": { "@hongminhee/x-forwarded-fetch@0.2.0": {
@ -108,10 +109,38 @@
"integrity": "sha512-vBZP4NlzfOlerQTnba4aqZoMhE/a9HY7HRqoOPaETQcSQuWEIyZMHGfVu6w9wGtGK5fED5qRs2DteVCjOH60sA==", "integrity": "sha512-vBZP4NlzfOlerQTnba4aqZoMhE/a9HY7HRqoOPaETQcSQuWEIyZMHGfVu6w9wGtGK5fED5qRs2DteVCjOH60sA==",
"dependencies": {} "dependencies": {}
}, },
"@graphql-typed-document-node/core@3.2.0_graphql@16.9.0": {
"integrity": "sha512-mB9oAsNCm9aM3/SOv4YtBMqZbYj10R7dkq8byBqxGY/ncFwhf2oQzMV+LCRlWoDSEBJ3COiR1yeDvMtsoOsuFQ==",
"dependencies": {
"graphql": "graphql@16.9.0"
}
},
"@ioredis/commands@1.2.0": { "@ioredis/commands@1.2.0": {
"integrity": "sha512-Sx1pU8EM64o2BrqNpEO1CNLtKQwyhuXuqyfH7oGKCk+1a33d2r5saW8zNwm3j6BTExtjrv2BxTgzzkMwts6vGg==", "integrity": "sha512-Sx1pU8EM64o2BrqNpEO1CNLtKQwyhuXuqyfH7oGKCk+1a33d2r5saW8zNwm3j6BTExtjrv2BxTgzzkMwts6vGg==",
"dependencies": {} "dependencies": {}
}, },
"@molt/command@0.9.0": {
"integrity": "sha512-1JI8dAlpqlZoXyKWVQggX7geFNPxBpocHIXQCsnxDjKy+3WX4SGyZVJXuLlqRRrX7FmQCuuMAfx642ovXmPA9g==",
"dependencies": {
"@molt/types": "@molt/types@0.2.0",
"alge": "alge@0.8.1",
"chalk": "chalk@5.3.0",
"lodash.camelcase": "lodash.camelcase@4.3.0",
"lodash.snakecase": "lodash.snakecase@4.1.1",
"readline-sync": "readline-sync@1.4.10",
"string-length": "string-length@6.0.0",
"strip-ansi": "strip-ansi@7.1.0",
"ts-toolbelt": "ts-toolbelt@9.6.0",
"type-fest": "type-fest@4.26.1",
"zod": "zod@3.23.8"
}
},
"@molt/types@0.2.0": {
"integrity": "sha512-p6ChnEZDGjg9PYPec9BK6Yp5/DdSrYQvXTBAtgrnqX6N36cZy37ql1c8Tc5LclfIYBNG7EZp8NBcRTYJwyi84g==",
"dependencies": {
"ts-toolbelt": "ts-toolbelt@9.6.0"
}
},
"@multiformats/base-x@4.0.1": { "@multiformats/base-x@4.0.1": {
"integrity": "sha512-eMk0b9ReBbV23xXU693TAIrLyeO5iTgBZGSJfpqriG8UkYvr/hC9u9pyMlAakDNHWmbhMZCDs6KQO0jzKD8OTw==", "integrity": "sha512-eMk0b9ReBbV23xXU693TAIrLyeO5iTgBZGSJfpqriG8UkYvr/hC9u9pyMlAakDNHWmbhMZCDs6KQO0jzKD8OTw==",
"dependencies": {} "dependencies": {}
@ -140,6 +169,19 @@
"event-target-shim": "event-target-shim@5.0.1" "event-target-shim": "event-target-shim@5.0.1"
} }
}, },
"alge@0.8.1": {
"integrity": "sha512-kiV9nTt+XIauAXsowVygDxMZLplZxDWt0W8plE/nB32/V2ziM/P/TxDbSVK7FYIUt2Xo16h3/htDh199LNPCKQ==",
"dependencies": {
"lodash.ismatch": "lodash.ismatch@4.4.0",
"remeda": "remeda@1.61.0",
"ts-toolbelt": "ts-toolbelt@9.6.0",
"zod": "zod@3.23.8"
}
},
"ansi-regex@6.1.0": {
"integrity": "sha512-7HSX4QQb4CspciLpVFwyRe79O3xsIZDDLER21kERQ71oaPodF8jL725AgJMFAYbooIqolJoRLuM81SpeUkpkvA==",
"dependencies": {}
},
"asn1js@3.0.5": { "asn1js@3.0.5": {
"integrity": "sha512-FVnvrKJwpt9LP2lAMl8qZswRNm3T4q9CON+bxldk2iwk3FFpuwhx2FfinyitizWHsVYyaY+y5JzDR0rCMV5yTQ==", "integrity": "sha512-FVnvrKJwpt9LP2lAMl8qZswRNm3T4q9CON+bxldk2iwk3FFpuwhx2FfinyitizWHsVYyaY+y5JzDR0rCMV5yTQ==",
"dependencies": { "dependencies": {
@ -156,6 +198,10 @@
"integrity": "sha512-0CNTVCLZggSh7bc5VkX5WWPWO+cyZbNd07IHIsSXLia/eAq+r836hgk+8BKoEh7949Mda87VUOitx5OddVj64A==", "integrity": "sha512-0CNTVCLZggSh7bc5VkX5WWPWO+cyZbNd07IHIsSXLia/eAq+r836hgk+8BKoEh7949Mda87VUOitx5OddVj64A==",
"dependencies": {} "dependencies": {}
}, },
"chalk@5.3.0": {
"integrity": "sha512-dLitG79d+GV1Nb/VYcCDFivJeK1hiukt9QjRNVOsUtTy1rR1YJsmpGGTZ3qJos+uw7WmWF4wUwBd9jxjocFC2w==",
"dependencies": {}
},
"cluster-key-slot@1.1.2": { "cluster-key-slot@1.1.2": {
"integrity": "sha512-RMr0FhtfXemyinomL4hrWcYJxmX6deFdCxpJzhDttxgO1+bcCnkk+9drydLVDmAMG7NE6aN/fl4F7ucU/90gAA==", "integrity": "sha512-RMr0FhtfXemyinomL4hrWcYJxmX6deFdCxpJzhDttxgO1+bcCnkk+9drydLVDmAMG7NE6aN/fl4F7ucU/90gAA==",
"dependencies": {} "dependencies": {}
@ -191,6 +237,20 @@
"fetch-blob": "fetch-blob@3.2.0" "fetch-blob": "fetch-blob@3.2.0"
} }
}, },
"graffle@8.0.0-next.68_@opentelemetry+api@1.9.0_graphql@16.9.0": {
"integrity": "sha512-oaigY1yEX48cUSiFJKtigjGw4ooA7JtLwafSUQuuAgbl0qtnaSmAGrfSRpb9RhxF0y/HEzJNEMYUaea085cn8w==",
"dependencies": {
"@graphql-typed-document-node/core": "@graphql-typed-document-node/core@3.2.0_graphql@16.9.0",
"@molt/command": "@molt/command@0.9.0",
"@opentelemetry/api": "@opentelemetry/api@1.9.0",
"graphql": "graphql@16.9.0",
"is-plain-obj": "is-plain-obj@4.1.0"
}
},
"graphql@16.9.0": {
"integrity": "sha512-GGTKBX4SD7Wdb8mqeDLni2oaRGYQWjWHGKPQ24ZMnUtKfcsVoiv4uX8+LJr1K6U5VW2Lu1BwJnj7uiori0YtRw==",
"dependencies": {}
},
"ioredis@5.4.1": { "ioredis@5.4.1": {
"integrity": "sha512-2YZsvl7jopIa1gaePkeMtd9rAcSjOOjPtpcLlOeusyO+XH2SK5ZcT+UCrElPP+WVIInh2TzeI4XW9ENaSLVVHA==", "integrity": "sha512-2YZsvl7jopIa1gaePkeMtd9rAcSjOOjPtpcLlOeusyO+XH2SK5ZcT+UCrElPP+WVIInh2TzeI4XW9ENaSLVVHA==",
"dependencies": { "dependencies": {
@ -205,6 +265,10 @@
"standard-as-callback": "standard-as-callback@2.1.0" "standard-as-callback": "standard-as-callback@2.1.0"
} }
}, },
"is-plain-obj@4.1.0": {
"integrity": "sha512-+Pgi+vMuUNkJyExiMBt5IlFoMyKnr5zhJ4Uspz58WOhBF5QoIZkFyNHIbBAtHwzVAgk5RtndVNsDRN61/mmDqg==",
"dependencies": {}
},
"json-canon@1.0.1": { "json-canon@1.0.1": {
"integrity": "sha512-PQcj4PFOTAQxE8PgoQ4KrM0DcKWZd7S3ELOON8rmysl9I8JuFMgxu1H9v+oZsTPjjkpeS3IHPwLjr7d+gKygnw==", "integrity": "sha512-PQcj4PFOTAQxE8PgoQ4KrM0DcKWZd7S3ELOON8rmysl9I8JuFMgxu1H9v+oZsTPjjkpeS3IHPwLjr7d+gKygnw==",
"dependencies": {} "dependencies": {}
@ -230,6 +294,10 @@
"integrity": "sha512-CasD9OCEQSFIam2U8efFK81Yeg8vNMTBUqtMOHlrcWQHqUX3HeCl9Dr31u4toV7emlH8Mymk5+9p0lL6mKb/Xw==", "integrity": "sha512-CasD9OCEQSFIam2U8efFK81Yeg8vNMTBUqtMOHlrcWQHqUX3HeCl9Dr31u4toV7emlH8Mymk5+9p0lL6mKb/Xw==",
"dependencies": {} "dependencies": {}
}, },
"lodash.camelcase@4.3.0": {
"integrity": "sha512-TwuEnCnxbc3rAvhf/LbG7tJUDzhqXyFnv3dtzLOPgCG/hODL7WFnsbwktkD7yUV0RrreP/l1PALq/YSg6VvjlA==",
"dependencies": {}
},
"lodash.defaults@4.2.0": { "lodash.defaults@4.2.0": {
"integrity": "sha512-qjxPLHd3r5DnsdGacqOMU6pb/avJzdh9tFX2ymgoZE27BmjXrNy/y4LoaiTeAb+O3gL8AfpJGtqfX/ae2leYYQ==", "integrity": "sha512-qjxPLHd3r5DnsdGacqOMU6pb/avJzdh9tFX2ymgoZE27BmjXrNy/y4LoaiTeAb+O3gL8AfpJGtqfX/ae2leYYQ==",
"dependencies": {} "dependencies": {}
@ -238,6 +306,14 @@
"integrity": "sha512-chi4NHZlZqZD18a0imDHnZPrDeBbTtVN7GXMwuGdRH9qotxAjYs3aVLKc7zNOG9eddR5Ksd8rvFEBc9SsggPpg==", "integrity": "sha512-chi4NHZlZqZD18a0imDHnZPrDeBbTtVN7GXMwuGdRH9qotxAjYs3aVLKc7zNOG9eddR5Ksd8rvFEBc9SsggPpg==",
"dependencies": {} "dependencies": {}
}, },
"lodash.ismatch@4.4.0": {
"integrity": "sha512-fPMfXjGQEV9Xsq/8MTSgUf255gawYRbjwMyDbcvDhXgV7enSZA0hynz6vMPnpAb5iONEzBHBPsT+0zes5Z301g==",
"dependencies": {}
},
"lodash.snakecase@4.1.1": {
"integrity": "sha512-QZ1d4xoBHYUeuouhEq3lk3Uq7ldgyFXGBhg04+oRLnIz8o9T65Eh+8YdroUwn846zchkA9yDsDl5CVVaV2nqYw==",
"dependencies": {}
},
"lru-cache@6.0.0": { "lru-cache@6.0.0": {
"integrity": "sha512-Jo6dJ04CmSjuznwJSS3pUeWmd/H0ffTlkXXgwZi+eq1UCmqQwCh+eLsYOYCwY991i2Fah4h1BEMCx4qThGbsiA==", "integrity": "sha512-Jo6dJ04CmSjuznwJSS3pUeWmd/H0ffTlkXXgwZi+eq1UCmqQwCh+eLsYOYCwY991i2Fah4h1BEMCx4qThGbsiA==",
"dependencies": { "dependencies": {
@ -288,6 +364,10 @@
"tslib": "tslib@2.7.0" "tslib": "tslib@2.7.0"
} }
}, },
"postgres@3.4.4": {
"integrity": "sha512-IbyN+9KslkqcXa8AO9fxpk97PA4pzewvpi2B3Dwy9u4zpV32QicaEdgmF3eSQUzdRk7ttDHQejNgAEr4XoeH4A==",
"dependencies": {}
},
"pvtsutils@1.3.5": { "pvtsutils@1.3.5": {
"integrity": "sha512-ARvb14YB9Nm2Xi6nBq1ZX6dAM0FsJnuk+31aUp4TrcZEdKUlSqOqsxJHUPJDNE3qiIp+iUPEIeR6Je/tgV7zsA==", "integrity": "sha512-ARvb14YB9Nm2Xi6nBq1ZX6dAM0FsJnuk+31aUp4TrcZEdKUlSqOqsxJHUPJDNE3qiIp+iUPEIeR6Je/tgV7zsA==",
"dependencies": { "dependencies": {
@ -304,6 +384,10 @@
"setimmediate": "setimmediate@1.0.5" "setimmediate": "setimmediate@1.0.5"
} }
}, },
"readline-sync@1.4.10": {
"integrity": "sha512-gNva8/6UAe8QYepIQH/jQ2qn91Qj0B9sYjMBBs3QOB8F2CXcKgLxQaJRP76sWVRQt+QU+8fAkCbCvjjMFu7Ycw==",
"dependencies": {}
},
"redis-errors@1.2.0": { "redis-errors@1.2.0": {
"integrity": "sha512-1qny3OExCf0UvUV/5wpYKf2YwPcOqXzkwKKSmKHiE6ZMQs5heeE/c8eXK+PNllPvmjgAbfnsbpkGZWy8cBpn9w==", "integrity": "sha512-1qny3OExCf0UvUV/5wpYKf2YwPcOqXzkwKKSmKHiE6ZMQs5heeE/c8eXK+PNllPvmjgAbfnsbpkGZWy8cBpn9w==",
"dependencies": {} "dependencies": {}
@ -314,6 +398,10 @@
"redis-errors": "redis-errors@1.2.0" "redis-errors": "redis-errors@1.2.0"
} }
}, },
"remeda@1.61.0": {
"integrity": "sha512-caKfSz9rDeSKBQQnlJnVW3mbVdFgxgGWQKq1XlFokqjf+hQD5gxutLGTTY2A/x24UxVyJe9gH5fAkFI63ULw4A==",
"dependencies": {}
},
"setimmediate@1.0.5": { "setimmediate@1.0.5": {
"integrity": "sha512-MATJdZp8sLqDl/68LfQmbP8zKPLQNV6BIZoIgrscFDQ+RsvK/BxeDQOgyxKKoh0y/8h3BqVFnCqQ/gd+reiIXA==", "integrity": "sha512-MATJdZp8sLqDl/68LfQmbP8zKPLQNV6BIZoIgrscFDQ+RsvK/BxeDQOgyxKKoh0y/8h3BqVFnCqQ/gd+reiIXA==",
"dependencies": {} "dependencies": {}
@ -322,10 +410,30 @@
"integrity": "sha512-qoRRSyROncaz1z0mvYqIE4lCd9p2R90i6GxW3uZv5ucSu8tU7B5HXUP1gG8pVZsYNVaXjk8ClXHPttLyxAL48A==", "integrity": "sha512-qoRRSyROncaz1z0mvYqIE4lCd9p2R90i6GxW3uZv5ucSu8tU7B5HXUP1gG8pVZsYNVaXjk8ClXHPttLyxAL48A==",
"dependencies": {} "dependencies": {}
}, },
"string-length@6.0.0": {
"integrity": "sha512-1U361pxZHEQ+FeSjzqRpV+cu2vTzYeWeafXFLykiFlv4Vc0n3njgU8HrMbyik5uwm77naWMuVG8fhEF+Ovb1Kg==",
"dependencies": {
"strip-ansi": "strip-ansi@7.1.0"
}
},
"strip-ansi@7.1.0": {
"integrity": "sha512-iq6eVVI64nQQTRYq2KtEg2d2uU7LElhTJwsH4YzIHZshxlgZms/wIc4VoDQTlG/IvVIrBKG06CrZnp0qv7hkcQ==",
"dependencies": {
"ansi-regex": "ansi-regex@6.1.0"
}
},
"ts-toolbelt@9.6.0": {
"integrity": "sha512-nsZd8ZeNUzukXPlJmTBwUAuABDe/9qtVDelJeT/qW0ow3ZS3BsQJtNkan1802aM9Uf68/Y8ljw86Hu0h5IUW3w==",
"dependencies": {}
},
"tslib@2.7.0": { "tslib@2.7.0": {
"integrity": "sha512-gLXCKdN1/j47AiHiOkJN69hJmcbGTHI0ImLmbYLHykhgeN0jVGola9yVjFgzCUklsZQMW55o+dW7IXv3RCXDzA==", "integrity": "sha512-gLXCKdN1/j47AiHiOkJN69hJmcbGTHI0ImLmbYLHykhgeN0jVGola9yVjFgzCUklsZQMW55o+dW7IXv3RCXDzA==",
"dependencies": {} "dependencies": {}
}, },
"type-fest@4.26.1": {
"integrity": "sha512-yOGpmOAL7CkKe/91I5O3gPICmJNLJ1G4zFYVAsRHg7M64biSnPtRj0WNQt++bRkjYOqjWXrhnUw1utzmVErAdg==",
"dependencies": {}
},
"uint8arrays@3.1.1": { "uint8arrays@3.1.1": {
"integrity": "sha512-+QJa8QRnbdXVpHYjLoTpJIdCTiw9Ir62nocClWuXIq2JIh4Uta0cQsTSpFL678p2CN8B+XSApwcU+pQEqVpKWg==", "integrity": "sha512-+QJa8QRnbdXVpHYjLoTpJIdCTiw9Ir62nocClWuXIq2JIh4Uta0cQsTSpFL678p2CN8B+XSApwcU+pQEqVpKWg==",
"dependencies": { "dependencies": {
@ -357,6 +465,10 @@
"yallist@4.0.0": { "yallist@4.0.0": {
"integrity": "sha512-3wdGidZyq5PB084XLES5TpOSRA3wjXAlIWMhum2kRcv/41Sn2emQ0dycQW4uZXLejwKvg6EsvbdlVL+FYEct7A==", "integrity": "sha512-3wdGidZyq5PB084XLES5TpOSRA3wjXAlIWMhum2kRcv/41Sn2emQ0dycQW4uZXLejwKvg6EsvbdlVL+FYEct7A==",
"dependencies": {} "dependencies": {}
},
"zod@3.23.8": {
"integrity": "sha512-XBx9AXhXktjUqnepgTiE5flcKIYWi/rme0Eaj+5Y0lftuGBq+jyRu/md4WnuxqgP1ubdpNCsYEYPxrzVHD8d6g==",
"dependencies": {}
} }
} }
}, },
@ -508,12 +620,13 @@
"workspace": { "workspace": {
"dependencies": [ "dependencies": [
"jsr:@fedify/fedify@^1.0.2", "jsr:@fedify/fedify@^1.0.2",
"jsr:@fedify/redis@^0.3.0", "jsr:@fedify/postgres@^0.1.0",
"jsr:@hongminhee/x-forwarded-fetch@^0.2.0", "jsr:@hongminhee/x-forwarded-fetch@^0.2.0",
"jsr:@logtape/logtape@^0.6.3", "jsr:@logtape/logtape@^0.6.3",
"jsr:@std/assert@1", "jsr:@std/assert@1",
"npm:@opentelemetry/api@^1.9.0", "npm:@opentelemetry/api@^1.9.0",
"npm:ioredis@^5.4.1" "npm:ioredis@^5.4.1",
"npm:postgres@^3.4.4"
] ]
} }
} }

175
src/database/index.ts Normal file
View file

@ -0,0 +1,175 @@
import Postgres from "@@npm/postgres"
import { getLogger } from "@logtape/logtape"
import { exportJwk, generateCryptoKeyPair, KvStore, MessageQueue } from "@fedify/fedify"
import { PostgresMessageQueue } from "@fedify/postgres"
import { PostgresKvStore } from "@fedify/postgres/kv"
const l = getLogger(["dotino-veloce", "database", "postgres"])
export type DbActor = {
handle: string,
public_rsa: JsonWebKey,
public_ed: JsonWebKey,
private_rsa: JsonWebKey,
private_ed: JsonWebKey,
}
export class Database {
sql: Postgres.Sql
constructor(connString: string) {
l.info`Creating Postgres object with string: ${connString}`
this.sql = Postgres(connString)
}
static fromEnv() {
l.debug`Getting connection string from environment variable DOTINO_POSTGRES_STRING...`
const connString = Deno.env.get("DOTINO_POSTGRES_STRING")
if(!connString) {
l.error`DOTINO_POSTGRES_STRING is unset.`
throw new Error("DOTINO_POSTGRES_STRING is unset.")
}
return new Database(connString)
}
useAsKvStore(): KvStore {
l.info`Creating Postgres key-value store...`
return new PostgresKvStore(this.sql, {})
}
useAsMessageQueue(): MessageQueue {
l.info`Creating Postgres message queue...`
return new PostgresMessageQueue(this.sql, {})
}
async #doQueryFile<T>(path: string, variables: Postgres.ParameterOrJSON<any>[] = []): Promise<Postgres.RowList<T[]>> {
try {
l.debug`Running query at ${path}...`
var results = await this.sql.file<T[]>(path, variables, undefined)
}
catch (e) {
l.error`Query at ${path} errored out with: ${e}`
throw e
}
l.debug`Query was successful, results are: ${results}`
return results
}
async reinitializeDev() {
l.fatal`!!! Re-initializing database from scratch for development !!!`
l.info`01/XX Dropping public schema from database...`
await this.#doQueryFile("src/database/init/01-drop-schema.sql")
l.info`02/XX Recreating public schema...`
await this.#doQueryFile("src/database/init/02-create-schema.sql")
l.info`03/XX Creating actor table...`
await this.#doQueryFile("src/database/init/03-create-actor.sql")
l.info`04/XX Creating service actor...`
l.debug`Creating RSA key pair...`
const {publicKey: publicRsa, privateKey: privateRsa} = await generateCryptoKeyPair("RSASSA-PKCS1-v1_5")
l.debug`Creating elliptic curve key pair...`
const {publicKey: publicEd, privateKey: privateEd} = await generateCryptoKeyPair("Ed25519")
l.debug`Exporting to JWK format...`
const publicRsaJwk = await exportJwk(publicRsa)
const publicEdJwk = await exportJwk(publicEd)
const privateRsaJwk = await exportJwk(privateRsa)
const privateEdJwk = await exportJwk(privateEd)
l.debug`Running SQL query...`
await this.#doQueryFile<DbActor>(
"src/database/init/04-insert-actor-app.sql",
[
publicRsaJwk,
publicEdJwk,
privateRsaJwk,
privateEdJwk,
]
)
l.info`05/XX Creating follow table...`
await this.#doQueryFile("src/database/init/05-create-follow.sql")
l.info("Done!")
}
async getActorApp(): Promise<DbActor> {
l.info`Getting app actor entity...`
const results = await this.#doQueryFile<DbActor>("src/database/query/get-actor_app.sql")
if(results.count == 0) {
l.error`No app actor entity exists.`
throw new Error("No app actor entity exists.")
}
else if(results.count > 1) {
l.error`Multiple app actor entities exist.`
throw new Error("Multiple app actor entities exist.")
}
l.debug`Attempting to get only result...`
const result = results[0]
l.debug`Filtered down to result: ${result}`
return result
}
async getActorPlayer(steamId: number): Promise<DbActor | null> {
l.info`Getting player actor entity with id: ${steamId}`
const results = await this.#doQueryFile<DbActor>("src/database/query/get-actor_player.sql", [steamId])
if(results.count == 0) {
l.debug`No such player actor entity exists.`
return null
}
else if(results.count > 1) {
l.error`Multiple player actor entities having the same SteamID exist.`
throw new Error("Multiple player actor entities having the same SteamID exist.")
}
l.debug`Attempting to get only result...`
const result = results[0]
l.debug`Filtered down to result: ${result}`
return result
}
async getActorGuild(guildId: number): Promise<DbActor | null> {
l.info`Getting guild actor entity with id: ${guildId}`
const results = await this.#doQueryFile<DbActor>("src/database/query/get-actor_guild.sql", [guildId])
if(results.count == 0) {
l.debug`No such guild actor entity exists.`
return null
}
else if(results.count > 1) {
l.error`Multiple guild actor entities having the same Guild ID exist.`
throw new Error("Multiple guild actor entities having the same Guild ID exist.")
}
l.debug`Attempting to get only result...`
const result = results[0]
l.debug`Filtered down to result: ${result}`
return result
}
async putFollow(follower: string, followed: string): Promise<void> {
l.info`Putting follow: from ${follower} to ${followed}`
await this.#doQueryFile<void>("src/database/query/put-follow.sql", [follower, followed])
}
async deleteFollow(follower: string, followed: string): Promise<void> {
l.info`Deleting follow: from ${follower} to ${followed}`
await this.#doQueryFile<void>("src/database/query/delete-follow.sql", [follower, followed])
}
}

View file

@ -0,0 +1 @@
DROP SCHEMA public CASCADE;

View file

@ -0,0 +1 @@
CREATE SCHEMA public;

View file

@ -0,0 +1,8 @@
CREATE TABLE actor (
handle VARCHAR PRIMARY KEY,
public_rsa JSON,
public_ed JSON,
private_rsa JSON,
private_ed JSON
);

View file

@ -0,0 +1,13 @@
INSERT INTO actor (
handle,
public_rsa,
public_ed,
private_rsa,
private_ed
) VALUES (
'app',
$1,
$2,
$3,
$4
);

View file

@ -0,0 +1,9 @@
CREATE TABLE follow (
follower VARCHAR NOT NULL,
followed VARCHAR REFERENCES actor (handle) NOT NULL,
PRIMARY KEY (
follower,
followed
)
);

View file

@ -0,0 +1,6 @@
DELETE FROM
follow
WHERE
follow.follower = $1
AND
follow.followed = $2;

View file

@ -0,0 +1,10 @@
SELECT
actor.handle,
actor.public_rsa,
actor.public_ed,
actor.private_rsa,
actor.private_ed
FROM
actor
WHERE
actor.handle = 'app';

View file

@ -0,0 +1,10 @@
SELECT
actor.handle,
actor.public_rsa,
actor.public_ed,
actor.private_rsa,
actor.private_ed
FROM
actor
WHERE
actor.handle = 'g' || $1;

View file

@ -0,0 +1,10 @@
SELECT
actor.handle,
actor.public_rsa,
actor.public_ed,
actor.private_rsa,
actor.private_ed
FROM
actor
WHERE
actor.handle = 'u' || $1;

View file

@ -0,0 +1,7 @@
INSERT INTO follow (
follower,
followed
) VALUES (
$1,
$2
) ON CONFLICT DO NOTHING;

18
src/deno/logging.ts Normal file
View file

@ -0,0 +1,18 @@
import { configure, getConsoleSink, getLogger } from "@logtape/logtape"
const l = getLogger(["dotino-veloce", "deno", "logging"])
export async function initLogging() {
await configure({
sinks: { console: getConsoleSink() },
filters: {},
loggers: [
{ category: ["logtape", "meta"], sinks: ["console"], level: "warning" },
{ category: ["fedify"], sinks: ["console"], level: "debug" },
{ category: ["dotino-veloce"], sinks: ["console"], level: "debug" },
],
})
l.info`Logging initialized successfully!`
}

45
src/deno/router.ts Normal file
View file

@ -0,0 +1,45 @@
import { getLogger } from "@logtape/logtape"
import { handleHostMeta } from "../dv/hostMeta.ts"
import { DotinoVeloce } from "../dv/index.ts"
import { handleFavicon } from "../dv/favicon.ts"
const l = getLogger(["dotino-veloce", "deno", "router"])
export function createRouter(ap: DotinoVeloce) {
return async function router(request: Request, _info: Deno.ServeHandlerInfo): Promise<Response> {
l.debug`Routing request: ${request}`
l.debug`Determining request's User-Agent...`
const agent = request.headers.get("User-Agent")
l.debug`Determining request's URL...`
const url = new URL(request.url)
l.debug`Determining request's pathname...`
const pathname = url.pathname
l.info`User-Agent: ${agent} | URL: ${url} | Pathname: ${pathname}`
if (url.pathname === "/favicon.ico") {
l.debug`Delegating handling to favicon handler...`
return await handleFavicon()
}
if (url.pathname === "/.well-known/host-meta")
{
l.debug`Delegating handling to host-meta generator...`
return await handleHostMeta(url.origin)
}
else
{
l.debug`Delegating request to federation handlers...`
return await ap.federation.fetch(
request,
{
contextData: undefined,
},
)
}
}
}

31
src/deno/server.ts Normal file
View file

@ -0,0 +1,31 @@
import { getLogger } from "https://jsr.io/@logtape/logtape/0.6.3/logtape/logger.ts"
const l = getLogger(["dotino-veloce", "deno", "server"])
export function doServe(router: Deno.ServeHandler) {
l.info`Starting server...`
Deno.serve(
{
port: 8080,
onListen(localAddr) {
l.info`Listening on: ${localAddr}`
},
// deno-lint-ignore require-await
async onError(error) {
l.error`Error caught at the serve boundary: ${error}`
return new Response(
"An internal server error has occurred.",
{
status: 500,
}
)
}
},
router,
)
}

196
src/dv/actor.ts Normal file
View file

@ -0,0 +1,196 @@
import { Actor, Application, Context, Endpoints, Image, Organization, Person, PropertyValue } from "@fedify/fedify"
import { ContextData } from "./index.ts"
import { getLogger } from "@logtape/logtape"
import { escapeHtml } from "@@x/escape"
import { DvComponent } from "./component.ts"
const l = getLogger(["dotino-veloce", "dv", "actor", "common"])
const lApp = getLogger(["dotino-veloce", "dv", "actor", "app"])
const lPlayer = getLogger(["dotino-veloce", "dv", "actor", "player"])
const lGuild = getLogger(["dotino-veloce", "dv", "actor", "guild"])
export class ActorComponent extends DvComponent {
static appMatcher = /app/
static playerMatcher = /u([0-9]+)/
static guildMatcher = /g([0-9]+)/
async getActor(ctx: Context<ContextData>, handle: string): Promise<Actor | null> {
l.info`Getting actor: ${handle}`
let actor = null
actor ??= await this.getAppActor(ctx, handle)
actor ??= await this.getPlayerActor(ctx, handle)
actor ??= await this.getGuildActor(ctx, handle)
l.debug`Obtained actor: ${handle}`
return actor
}
async getCommonActorProperties(ctx: Context<ContextData>, handle: string): Promise<Partial<Actor>> {
l.info`Generating common actor properties for ${handle}...`
const properties = {
preferredUsername: handle,
id: ctx.getActorUri(handle),
// This is required for compatibility with a whole lot of servers
publicKeys: (await ctx.getActorKeyPairs(handle)).map(keyPair => keyPair.cryptographicKey),
assertionMethods: (await ctx.getActorKeyPairs(handle)).map(keyPair => keyPair.multikey),
// Akkoma requires inboxes to be setup to display profiles
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/web/activity_pub/object_validators/user_validator.ex#L72
inbox: ctx.getInboxUri(handle),
endpoints: new Endpoints({
sharedInbox: ctx.getInboxUri(),
}),
}
l.debug`Generated common actor properties for ${handle}: ${properties}`
return properties
}
async getAppActor(ctx: Context<ContextData>, handle: string): Promise<Actor | null> {
lApp.debug`Checking if handle ${handle} matches regex for the app account...`
const match = handle.match(ActorComponent.appMatcher)
if(!match) {
lApp.debug`No match for app account regex, returning null.`
return null
}
lApp.info`Attempting to generate ActivityPub actor for app...`
lApp.debug`Creating ActivityPub actor for app...`
const actor = new Application({
...(await this.getCommonActorProperties(ctx, handle)),
name: "[TEST] Dotino Veloce",
summary: "App account of a Dotino Veloce instance.",
attachments: [
new PropertyValue({
name: "Source code",
value: `<a href="https://forge.steffo.eu/steffo/dotino-veloce">https://forge.steffo.eu/steffo/dotino-veloce</a>`,
}),
]
})
lApp.debug`Generated ActivityPub actor for service: ${actor}`
return actor
}
async getPlayerActor(ctx: Context<ContextData>, handle: string): Promise<Actor | null> {
lPlayer.debug`Checking if handle ${handle} matches regex for player accounts...`
const match = handle.match(ActorComponent.playerMatcher)
if(!match) {
lPlayer.debug`No match for player account regex, returning null.`
return null
}
lApp.info`Attempting to generate ActivityPub actor for player...`
lPlayer.debug`Getting handle ${handle}'s SteamID...`
const steamId = Number.parseInt(match[1] as any)
lPlayer.debug`Handle ${handle}'s SteamID seems to be: ${steamId}`
lPlayer.debug`Making sure the SteamID parsing didn't explode...`
if(!Number.isFinite(steamId)) {
lPlayer.error`SteamID parsing for ${handle} exploded with ${steamId}, returning null.`
return null
}
lPlayer.debug`Getting player data for ${steamId}...`
const player = await this.dv.stratz.doQueryPlayer(steamId)
if(player === null) {
lPlayer.debug`No Steam account was found with ID: ${steamId}`
return null
}
lPlayer.debug`Creating ActivityPub actor for player ${steamId}...`
const actor = new Person({
...(await this.getCommonActorProperties(ctx, handle)),
name: `[TEST] ${escapeHtml(player.name)}`,
icon: new Image({
url: new URL(player.avatar),
mediaType: "image/jpeg"
}),
attachments: [
new PropertyValue({
name: "Steam",
value: `<a href="https://steamcommunity.com/profiles/[U:1:${player.id}]">https://steamcommunity.com/profiles/[U:1:${player.id}]</a>`,
}),
new PropertyValue({
name: "STRATZ",
value: `<a href="https://stratz.com/players/${player.id}">https://stratz.com/players/${player.id}</a>`,
}),
new PropertyValue({
name: "OpenDota",
value: `<a href="https://www.opendota.com/players/${player.id}">https://www.opendota.com/players/${player.id}</a>`,
}),
new PropertyValue({
name: "DOTABUFF",
value: `<a href="https://www.dotabuff.com/players/${player.id}">https://www.dotabuff.com/players/${player.id}</a>`,
}),
],
})
lPlayer.debug`Generated ActivityPub actor for player ${steamId}: ${actor}`
return actor
}
async getGuildActor(ctx: Context<ContextData>, handle: string): Promise<Actor | null> {
lGuild.debug`Checking if handle ${handle} matches regex for guild accounts...`
const match = handle.match(ActorComponent.guildMatcher)
if(!match) {
lGuild.debug`No match for guild account regex, returning null.`
return null
}
lApp.info`Attempting to generate ActivityPub actor for guild...`
lGuild.debug`Getting handle ${handle}'s Guild ID...`
const guildId = Number.parseInt(match[1] as any)
lGuild.debug`Handle ${handle}'s Guild ID seems to be: ${guildId}`
lGuild.debug`Making sure the Guild ID parsing didn't explode...`
if(Number.isFinite(guildId)) {
lGuild.error`Guild ID parsing for ${handle} exploded with ${guildId}, returning null.`
return null
}
lPlayer.debug`Getting guild data for ${guildId}...`
const guild = await this.dv.stratz.doQueryGuild(guildId)
if(guild === null) {
lGuild.warn`No guild was found with ID: ${guildId}`
return null
}
lGuild.debug`Creating ActivityPub actor for guild ${guildId}...`
const actor = new Organization({
...(await this.getCommonActorProperties(ctx, handle)),
name: `[TEST] ${escapeHtml(guild.name)}`,
summary: escapeHtml(guild.description),
icon: new Image({
url: new URL(`https://steamusercontent-a.akamaihd.net/ugc/${guild.logo}`),
mediaType: "image/jpeg"
}),
published: Temporal.Instant.fromEpochMilliseconds(guild.createdDateTime * 1000),
attachments: [
new PropertyValue({
name: "Tag",
value: `[<b>${escapeHtml(guild.tag)}</b>]`,
}),
new PropertyValue({
name: "Message of the day",
value: escapeHtml(guild.motd),
}),
new PropertyValue({
name: "STRATZ",
value: `<a href="https://stratz.com/guilds/${guild.id}">https://stratz.com/guilds/${guild.id}</a>`,
}),
]
})
lGuild.debug`Generated ActivityPub actor for guild ${guildId}: ${actor}`
return actor
}
}

15
src/dv/component.ts Normal file
View file

@ -0,0 +1,15 @@
import { getLogger } from "@logtape/logtape"
import { DotinoVeloce } from "./index.ts"
const l = getLogger(["dotino-veloce", "dv", "component"])
export class DvComponent {
dv: DotinoVeloce
constructor(dv: DotinoVeloce) {
l.debug`Instantiating DvComponent...`
this.dv = dv
}
}

18
src/dv/favicon.ts Normal file
View file

@ -0,0 +1,18 @@
import { getLogger } from "@logtape/logtape"
const l = getLogger(["dotino-veloce", "dv", "favicon"])
export async function handleFavicon(): Promise<Response> {
l.info`Returning favicon...`
return new Response(
await Deno.readFile(".media/icon-128x128_round.png"),
{
headers: {
"Content-Type": "image/png",
},
},
)
}

114
src/dv/follow.ts Normal file
View file

@ -0,0 +1,114 @@
import { getLogger } from "@logtape/logtape"
import { ContextData } from "./index.ts"
import { Accept, Context, Follow, Reject } from "@fedify/fedify"
import { DvComponent } from "./component.ts"
const lPlus = getLogger(["dotino-veloce", "dv", "follow", "plus"])
const lMinus = getLogger(["dotino-veloce", "dv", "follow", "minus"])
export class FollowComponent extends DvComponent {
async handlePlus(ctx: Context<ContextData>, follow: Follow) {
lPlus.debug`Received Follow activity: ${follow}`
if(!follow.id) {
lPlus.warn`Missing follow ID, skipping.`
return
}
if(!follow.actorId) {
lPlus.warn`Missing actor ID, skipping.`
return
}
if(!follow.objectId) {
lPlus.warn`Missing object ID, skipping.`
return
}
lPlus.debug`Attempting to determine who sent the follow request...`
const actor = await follow.getActor(ctx)
if(!actor) {
lPlus.warn`Failed to determine who sent the follow request, skipping.`
return
}
lPlus.debug`Attempting to determine who is being followed...`
const object = ctx.parseUri(follow.objectId)
if(!object) {
lPlus.warn`Failed to determine who is being followed, skipping.`
return
}
if(object.type !== "actor") {
lPlus.warn`Attempting to follow something that is not actor, skipping.`
return
}
lPlus.info`Confirming follow request from ${follow.actorId} to ${follow.objectId}...`
lPlus.debug`Storing follow information in the database...`
this.dv.db.putFollow(follow.actorId.toString(), follow.objectId.toString())
lPlus.debug`Sending follow Accept activity...`
await ctx.sendActivity(object, "followers", new Accept({
object: follow,
actor: follow.objectId,
to: follow.actorId,
}))
lPlus.debug`Successfully accepted follow request!`
}
async handleMinus(ctx: Context<ContextData>, follow: Follow) {
lMinus.debug`Received Undo Follow activity: ${follow}`
if(!follow.id) {
lMinus.warn`Missing follow ID, skipping.`
return
}
if(!follow.actorId) {
lMinus.warn`Missing actor ID, skipping.`
return
}
if(!follow.objectId) {
lMinus.warn`Missing object ID, skipping.`
return
}
lMinus.debug`Attempting to determine who sent the follow request...`
const actor = await follow.getActor(ctx)
if(!actor) {
lMinus.warn`Failed to determine who sent the follow request, skipping.`
return
}
lMinus.debug`Attempting to determine who is being followed...`
const object = ctx.parseUri(follow.objectId)
if(!object) {
lMinus.warn`Failed to determine who is being followed, skipping.`
return
}
if(object.type !== "actor") {
lMinus.warn`Attempting to follow something that is not actor, skipping.`
return
}
lMinus.info`Undoing follow request from ${follow.actorId} to ${follow.objectId}...`
lMinus.debug`Deleting follow information from the database...`
this.dv.db.deleteFollow(follow.actorId.toString(), follow.objectId.toString())
// Do I really need to do this?
lMinus.debug`Sending follow Reject activity...`
await ctx.sendActivity(object, "followers", new Reject({
object: follow,
actor: follow.objectId,
to: follow.actorId,
}))
lMinus.debug`Successfully undone follow request!`
}
}

21
src/dv/hostMeta.ts Normal file
View file

@ -0,0 +1,21 @@
import { getLogger } from "@logtape/logtape"
const l = getLogger(["dotino-veloce", "dv", "hostMeta"])
// deno-lint-ignore require-await
export async function handleHostMeta(origin: string): Promise<Response> {
l.info`Creating host-meta definition for: ${origin}`
// Akkoma expects host-meta to be correctly setup
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/web/web_finger.ex#L177
return new Response(
`<?xml version="1.0" encoding="UTF-8"?><XRD xmlns="http://docs.oasis-open.org/ns/xri/xrd-1.0"><Link type="application/xrd+xml" template="${origin}/.well-known/webfinger?resource={uri}" rel="lrdd" /></XRD>`,
{
headers: {
"Content-Type": "application/xml",
},
},
)
}

62
src/dv/index.ts Normal file
View file

@ -0,0 +1,62 @@
import { createFederation, Federation, Follow, Undo } from "@fedify/fedify"
import { getLogger } from "https://jsr.io/@logtape/logtape/0.6.3/logtape/logger.ts"
import { StratzAPI } from "../stratz/api.ts"
import { Database } from "../database/index.ts"
import { NodeInfoComponent } from "./nodeinfo.ts"
import { ActorComponent } from "./actor.ts"
import { KeyComponent } from "./key.ts"
import { FollowComponent } from "./follow.ts"
import { UndoComponent } from "./undo.ts"
const l = getLogger(["dotino-veloce", "dv", "index"])
export type ContextData = undefined
export class DotinoVeloce {
db: Database
stratz: StratzAPI
federation: Federation<ContextData>
cNodeInfo: NodeInfoComponent
cActor: ActorComponent
cKey: KeyComponent
cFollow: FollowComponent
cUndo: UndoComponent
constructor(db: Database, stratz: StratzAPI) {
this.db = db
this.stratz = stratz
this.cNodeInfo = new NodeInfoComponent(this)
this.cActor = new ActorComponent(this)
this.cKey = new KeyComponent(this)
this.cFollow = new FollowComponent(this)
this.cUndo = new UndoComponent(this)
this.federation = createFederation<ContextData>({
kv: db.useAsKvStore(),
queue: db.useAsMessageQueue(),
})
this.federation
.setActorDispatcher("/users/{identifier}", this.cActor.getActor.bind(this.cActor))
.setKeyPairsDispatcher(this.cKey.getActorKeys.bind(this.cKey))
.mapHandle((_, h) => h)
this.federation
.setInboxListeners("/inbox/{identifier}", "/inbox")
// Akkoma with Authorized Fetch requires this to be set
// https://p.junimo.party/#/junimo.party/s/AnFW6s3OURPMY04LKq?view=full
.setSharedKeyDispatcher(this.cKey.getFetchKey.bind(this.cKey))
.on(Follow, this.cFollow.handlePlus.bind(this.cFollow))
.on(Undo, this.cUndo.handle.bind(this.cUndo))
this.federation
.setNodeInfoDispatcher("/nodeinfo/2.1", this.cNodeInfo.handle.bind(this.cNodeInfo))
}
// REMINDER: A pattern matcher on received activities could be useful, actually.
}

68
src/dv/key.ts Normal file
View file

@ -0,0 +1,68 @@
import { Context, importJwk, SenderKeyPair } from "@fedify/fedify"
import { ContextData } from "./index.ts"
import { getLogger } from "@logtape/logtape"
import { DvComponent } from "./component.ts"
const lActor = getLogger(["dotino-veloce", "dv", "key", "actor"])
const lFetch = getLogger(["dotino-veloce", "dv", "key", "fetch"])
export class KeyComponent extends DvComponent {
async getActorKeys(_ctx: Context<ContextData>, handle: string): Promise<CryptoKeyPair[]> {
lActor.info`Getting actor keys for: ${handle}`
lActor.debug`Requesting keys from the database...`
const {
public_rsa: publicRsaJwk,
public_ed: publicEdJwk,
private_rsa: privateRsaJwk,
private_ed: privateEdJwk,
} = await this.dv.db.getActorApp()
lActor.debug`Importing keys from JWK format...`
const publicRsa = await importJwk(publicRsaJwk, "public")
const publicEd = await importJwk(publicEdJwk, "public")
const privateRsa = await importJwk(privateRsaJwk, "private")
const privateEd = await importJwk(privateEdJwk, "private")
lActor.debug`Bundling keys...`
const result = [
{
publicKey: publicRsa,
privateKey: privateRsa,
},
{
publicKey: publicEd,
privateKey: privateEd,
}
]
lActor.debug`Bundled keys are: ${result}`
return result
}
async getFetchKey(ctx: Context<ContextData>): Promise<SenderKeyPair> {
lFetch.info`Getting fetch key...`
lFetch.debug`Requesting key from the database...`
const {
private_rsa: privateKeyJwk,
} = await this.dv.db.getActorApp()
lFetch.debug`Importing key from JWK format...`
const privateKey = await importJwk(privateKeyJwk, "private")
lFetch.debug`Getting app actor URI...`
const keyId = ctx.getActorUri("app")
lFetch.debug`Appending #main-key to the app actor URI...`
keyId.hash = "main-key"
lFetch.debug`Bundling key...`
const result = {privateKey, keyId}
lFetch.debug`Bundled key is: ${result}`
return result
}
}

35
src/dv/nodeinfo.ts Normal file
View file

@ -0,0 +1,35 @@
import { Context, NodeInfo } from "@fedify/fedify"
import { ContextData } from "./index.ts"
import { getLogger } from "@logtape/logtape"
import { DvComponent } from "./component.ts"
const l = getLogger(["dotino-veloce", "dv", "nodeinfo"])
export class NodeInfoComponent extends DvComponent {
handle(_ctx: Context<ContextData>): NodeInfo {
l.debug`Creating nodeinfo...`
return {
software: {
name: "dotino-veloce",
version: {
major: 0,
minor: 1,
patch: 0,
},
repository: new URL("https://forge.steffo.eu/steffo/dotino-veloce"),
},
protocols: ["activitypub"],
usage: {
users: {
total: 0,
activeHalfyear: 0,
activeMonth: 0,
},
localPosts: 0,
localComments: 0,
}
}
}
}

14
src/dv/undo.ts Normal file
View file

@ -0,0 +1,14 @@
import { getLogger } from "@logtape/logtape"
import { ContextData } from "./index.ts"
import { Context, Undo } from "@fedify/fedify"
import { DvComponent } from "./component.ts"
const l = getLogger(["dotino-veloce", "dv", "undo"])
export class UndoComponent extends DvComponent {
async handle(_ctx: Context<ContextData>, undo: Undo) {
l.error`Not implemented: ${undo}`
}
}

12
src/entry/dbInit.ts Normal file
View file

@ -0,0 +1,12 @@
import { Database } from "../database/index.ts"
import { initLogging } from "../deno/logging.ts"
async function entryDbInit() {
await initLogging()
const db = Database.fromEnv()
await db.reinitializeDev()
}
entryDbInit()

21
src/entry/server.ts Normal file
View file

@ -0,0 +1,21 @@
import { doServe } from "../deno/server.ts"
import { initLogging } from "../deno/logging.ts"
import { StratzAPI } from "../stratz/api.ts"
import { behindProxy, Fetch } from "@hongminhee/x-forwarded-fetch"
import { createRouter } from "../deno/router.ts"
import { DotinoVeloce } from "../dv/index.ts"
import { Database } from "../database/index.ts"
async function entryServer() {
await initLogging()
const db = Database.fromEnv()
const stratz = StratzAPI.fromEnv()
const ap = new DotinoVeloce(db, stratz)
const router = createRouter(ap)
const routerBehindProxy = behindProxy(router as Fetch)
await doServe(routerBehindProxy)
}
entryServer()

View file

@ -1,140 +0,0 @@
import { createFederation, Person, Application, Image, PropertyValue, Organization, Group } from "@fedify/fedify"
import { kv } from "./redis.ts"
import { getLogger } from "https://jsr.io/@logtape/logtape/0.6.3/logtape/logger.ts"
import { doQueryGuild, doQueryPlayer } from "./graphql/stratz.ts"
import { escapeHtml } from "@@x/escape"
const l = getLogger(["dotino-veloce", "federation"])
l.debug`Creating federation object...`
export const federation = createFederation<void>({ kv })
const userMatcher = /u([0-9]+)/
const guildMatcher = /g([0-9]+)/
l.debug`Creating actor dispatcher...`
// deno-lint-ignore require-await
async function actorDispatcher(ctx: any, handle: string) {
l.debug`Determining id of requested actor: ${handle}`
const id = ctx.getActorUri(handle)
l.debug`Requested actor is: ${id.href}`
if (handle === "service") {
l.info`Dispatching service account...`
return new Application({
id,
preferredUsername: id.href,
// Akkoma expects URL to be equal to ID
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/object/fetcher.ex#L287
url: id,
// Akkoma requires inboxes to be setup to display profiles
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/web/activity_pub/object_validators/user_validator.ex#L72
inbox: ctx.getInboxUri(handle),
name: "[TEST] Dotino Veloce",
summary: "Service account of a Dotino Veloce instance.",
})
}
const steamId = Number.parseInt(handle.match(userMatcher)?.[1] as any)
if(Number.isFinite(steamId)) {
l.info`Dispatching user account with Steam ID: ${steamId}`
const player = await doQueryPlayer(steamId)
if(player === null) {
l.warn`No Steam account was found with ID: ${steamId}`
return null
}
return new Person({
id,
preferredUsername: id.href,
// Akkoma expects URL to be equal to ID
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/object/fetcher.ex#L287
url: id,
// Akkoma requires inboxes to be setup to display profiles
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/web/activity_pub/object_validators/user_validator.ex#L72
inbox: ctx.getInboxUri(handle),
name: `[TEST] ${escapeHtml(player.name)}`,
icon: new Image({
url: new URL(player.avatar),
mediaType: "image/jpeg"
}),
attachments: [
new PropertyValue({
name: "Steam",
value: `<a href="https://steamcommunity.com/profiles/[U:1:${player.id}]">https://steamcommunity.com/profiles/[U:1:${player.id}]</a>`,
}),
new PropertyValue({
name: "STRATZ",
value: `<a href="https://stratz.com/players/${player.id}">https://stratz.com/players/${player.id}</a>`,
}),
new PropertyValue({
name: "OpenDota",
value: `<a href="https://www.opendota.com/players/${player.id}">https://www.opendota.com/players/${player.id}</a>`,
}),
new PropertyValue({
name: "DOTABUFF",
value: `<a href="https://www.dotabuff.com/players/${player.id}">https://www.dotabuff.com/players/${player.id}</a>`,
}),
]
})
}
const guildId = Number.parseInt(handle.match(guildMatcher)?.[1] as any)
if(Number.isFinite(guildId)) {
l.info`Dispatching guild with Guild ID: ${guildId}`
const guild = await doQueryGuild(guildId)
if(guild === null) {
l.warn`No guild was found with ID: ${guildId}`
return null
}
return new Group({
id,
preferredUsername: id.href,
// Akkoma expects URL to be equal to ID
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/object/fetcher.ex#L287
url: id,
// Akkoma requires inboxes to be setup to display profiles
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/web/activity_pub/object_validators/user_validator.ex#L72
inbox: ctx.getInboxUri(handle),
name: `[TEST] ${escapeHtml(guild.name)}`,
summary: escapeHtml(guild.description),
icon: new Image({
url: new URL(`https://steamusercontent-a.akamaihd.net/ugc/${guild.logo}`),
mediaType: "image/jpeg"
}),
published: Temporal.Instant.fromEpochMilliseconds(guild.createdDateTime * 1000),
attachments: [
new PropertyValue({
name: "Tag",
value: `[<b>${escapeHtml(guild.tag)}</b>]`,
}),
new PropertyValue({
name: "Message of the day",
value: escapeHtml(guild.motd),
}),
new PropertyValue({
name: "STRATZ",
value: `<a href="https://stratz.com/guilds/${guild.id}">https://stratz.com/guilds/${guild.id}</a>`,
}),
]
})
}
l.warn`No dispatcher was found for handle: ${handle}`
return null
}
l.debug`Connecting actor dispatcher to federation object...`
federation.setActorDispatcher("/users/{identifier}", actorDispatcher)
l.debug`Initializing inbox listener...`
federation.setInboxListeners("/inbox/{identifier}") // I don't really care about the shared inbox for this project

View file

@ -1,99 +0,0 @@
import { getLogger } from "@logtape/logtape"
const l = getLogger(["dotino-veloce", "graphql"])
l.debug`Getting Stratz API URL from environment variable DOTINO_STRATZ_URL...`
const urlString = Deno.env.get("DOTINO_STRATZ_URL")
if(!urlString) {
l.error`DOTINO_STRATZ_URL is unset.`
throw new Error("DOTINO_STRATZ_URL is unset.")
}
l.debug`Attempting to parse Stratz API URL...`
const url = new URL(urlString)
l.debug`Getting Stratz API key from environment variable DOTINO_STRATZ_KEY...`
const key = Deno.env.get("DOTINO_STRATZ_KEY")
if(!key) {
l.error`DOTINO_STRATZ_KEY is unset.`
throw new Error("DOTINO_STRATZ_KEY is unset.")
}
// Little trick to get VSCode to highlight queries!
const graphql = String.raw
export async function doQuery(query: string, variables: object) {
const request = await fetch(url, {
method: "POST",
headers: {
"Content-Type": "application/json",
"Accept": "application/json",
"Authorization": `Bearer ${key}`,
"User-Agent": "STRATZ_API",
},
body: JSON.stringify({query, variables})
})
const data = await request.json()
if(data["error"]) {
throw new Error("GraphQL query failed.", data["error"])
}
return data["data"]
}
export async function doQueryPlayer(steamId: number): Promise<{
communityVisibleState: number,
isAnonymous: boolean,
id: number,
name: string,
avatar: string,
} | null> {
l.info`Querying player ${steamId} on the Stratz API...`
const response = await doQuery(
graphql`
query ($steamId: Long!) {
player (steamAccountId: $steamId) {
steamAccount {
communityVisibleState
isAnonymous
id
name
avatar
}
}
}
`,
{steamId}
)
return response?.player?.steamAccount ?? null
}
export async function doQueryGuild(guildId: number): Promise<{
id: number,
motd: string,
name: string,
tag: string,
logo: string,
description: string,
createdDateTime: number,
} | null> {
l.info`Querying guild ${guildId} on the Stratz API...`
const response = await doQuery(
graphql`
query ($guildId: Int!) {
guild(id: $guildId) {
id,
motd,
name,
tag,
logo,
description,
createdDateTime,
}
}
`,
{guildId}
)
return response?.guild ?? null
}

View file

@ -1,40 +0,0 @@
import { getLogger } from "@logtape/logtape"
import { behindProxy, Fetch } from "@hongminhee/x-forwarded-fetch"
import { federation } from "./federation.ts"
const l = getLogger(["dotino-veloce", "handler"])
l.debug`Creating Deno handler...`
function handler(request: Request, _info: Deno.ServeHandlerInfo) {
l.debug`Received a request, processing...`
const agent = request.headers.get("User-Agent")
const requestUrl = new URL(request.url)
l.debug`Received request from ${agent} to ${requestUrl.href}`
// Akkoma expects host-meta to be correctly setup
// https://akkoma.dev/AkkomaGang/akkoma/src/commit/f1018867097e6f293d8b2b5b6935f0a7ebf99bd0/lib/pleroma/web/web_finger.ex#L177
l.debug`Routing request to: ${requestUrl.pathname}`
if (requestUrl.pathname === "/.well-known/host-meta") {
l.debug`Intercepting request to inject host-meta for ${requestUrl.origin}`
return new Response(
`<?xml version="1.0" encoding="UTF-8"?><XRD xmlns="http://docs.oasis-open.org/ns/xri/xrd-1.0"><Link type="application/xrd+xml" template="${requestUrl.origin}/.well-known/webfinger?resource={uri}" rel="lrdd" /></XRD>`,
{
headers: {
"Content-Type": "application/xml",
},
},
)
}
l.debug`Delegating request to Federation...`
return federation.fetch(
request,
{
contextData: undefined,
},
)
}
l.debug`Creating proxyied Deno handler...`
export const proxyHandler: Deno.ServeHandler = behindProxy(handler as Fetch) // Should be good.

View file

@ -1,24 +0,0 @@
import { configure, getConsoleSink, getLogger } from "@logtape/logtape"
import { proxyHandler } from "./handler.ts"
await configure({
sinks: { console: getConsoleSink() },
filters: {},
loggers: [
{ category: ["logtape", "meta"], sinks: ["console"], level: "warning" },
{ category: ["fedify"], sinks: ["console"], level: "info" },
{ category: ["dotino-veloce"], sinks: ["console"], level: "debug" },
],
})
const l = getLogger(["dotino-veloce", "main"])
l.info`Starting server...`
Deno.serve(
{
port: 8080,
onListen: (_localAddr) => {
},
},
proxyHandler,
)

View file

@ -1,11 +0,0 @@
import { RedisKvStore } from "@fedify/redis"
import { getLogger } from "@logtape/logtape"
import { Redis } from "@@npm/ioredis"
const l = getLogger(["dotino-veloce", "redis"])
l.debug`Creating redis object...`
export const redis = new Redis({})
l.debug`Creating federation object...`
export const kv = new RedisKvStore(redis, {})

143
src/stratz/api.ts Normal file
View file

@ -0,0 +1,143 @@
import { getLogger } from "@logtape/logtape"
const l = getLogger(["dotino-veloce", "stratz", "api"])
const graphql = String.raw
export type QueryPlayer = {
communityVisibleState: number,
isAnonymous: boolean,
id: number,
name: string,
avatar: string,
}
export type QueryGuild = {
id: number,
motd: string,
name: string,
tag: string,
logo: string,
description: string,
createdDateTime: number,
}
export class StratzAPI {
url: URL
key: string
constructor(url: string, key: string) {
l.info`Creating new Stratz API client sending requests at: ${url}`
l.debug`Using Stratz API key: ${key}`
this.key = key
l.debug`Attempting to parse Stratz API URL...`
this.url = new URL(url)
l.debug`Stratz API URL is: ${this.url}`
}
static fromEnv(): StratzAPI {
l.debug`Getting Stratz API URL from environment variable DOTINO_STRATZ_URL...`
const url = Deno.env.get("DOTINO_STRATZ_URL")
if(!url) {
l.error`DOTINO_STRATZ_URL is unset.`
throw new Error("DOTINO_STRATZ_URL is unset.")
}
l.debug`Getting Stratz API key from environment variable DOTINO_STRATZ_KEY...`
const key = Deno.env.get("DOTINO_STRATZ_KEY")
if(!key) {
l.error`DOTINO_STRATZ_KEY is unset.`
throw new Error("DOTINO_STRATZ_KEY is unset.")
}
return new StratzAPI(url, key)
}
async doQuery(query: string, variables: object): Promise<any> {
l.debug`Sending to Stratz API at ${this.url} query ${query} with variables ${variables}`
const response = await fetch(this.url, {
method: "POST",
headers: {
"Content-Type": "application/json",
"Accept": "application/json",
"Authorization": `Bearer ${this.key}`,
"User-Agent": "STRATZ_API", // Stratz requires this specific User-Agent in API calls
},
body: JSON.stringify({query, variables})
})
l.debug`Received Stratz API response: ${response}`
l.debug`Parsing Stratz API response as JSON...`
const parsed = await response.json()
l.debug`Parsed Stratz API response as: ${parsed}`
const error = parsed["error"]
if(error) {
l.error`GraphQL query failed: ${error}`
throw new Error("GraphQL query failed.", error)
}
l.debug`Attempting to get data from the parsed API response...`
const data = parsed["data"]
l.debug`Got data from the parsed API response: ${data}`
return data
}
async doQueryPlayer(steamId: number): Promise<QueryPlayer | null> {
const query = graphql`
query ($steamId: Long!) {
player (steamAccountId: $steamId) {
steamAccount {
communityVisibleState
isAnonymous
id
name
avatar
}
}
}
`
const variables = {steamId}
l.info`Querying player ${steamId} on the Stratz API...`
const response = await this.doQuery(query, variables)
l.debug`Player query successful, received: ${response}`
l.debug`Attempting to retrieve player's Steam account from the Stratz API response...`
const steamAccount = response?.player?.steamAccount ?? null
l.debug`Player's Steam account is: ${steamAccount}`
return steamAccount
}
async doQueryGuild(guildId: number): Promise<QueryGuild | null> {
const query = graphql`
query ($guildId: Int!) {
guild(id: $guildId) {
id,
motd,
name,
tag,
logo,
description,
createdDateTime,
}
}
`
const variables = {guildId}
l.info`Querying guild ${guildId} on the Stratz API...`
const response = await this.doQuery(query, variables)
l.debug`Player query successful, received: ${response}`
l.debug`Attempting to retrieve guild data from the Stratz API response...`
const guildData = response?.guild ?? null
l.debug`Guild data is: ${guildData}`
return guildData
}
}

View file

@ -1,5 +1,5 @@
import { configure, getConsoleSink } from "@logtape/logtape" import { configure, getConsoleSink } from "@logtape/logtape"
import { doQueryPlayer } from "../src/graphql/stratz.ts" import { doQueryPlayer } from "../src/stratz/api.ts"
import { assert, assertEquals} from "@std/assert" import { assert, assertEquals} from "@std/assert"