fediverse
/
activity-kit-core
mirror of https://github.com/michaelcpuckett/activity-kit.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Requests

This commit is contained in:
Michael Puckett 2023-07-22 18:27:39 -04:00
parent ace4fb858e
commit 758115744c
14 changed files with 107 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/endpoints/lib/inbox/sideEffects/accept.js
View File

@ -61,6 +61,9 @@ async function handleAccept(activity, recipient) {
return;
}
await this.core.insertItem(followingId, followeeId);
const requests = await this.core.getStreamByName(follower, 'Requests');
const requestsId = (0, utilities_1.getId)(requests);
await this.core.removeItem(requestsId, (0, utilities_1.getId)(followActivity));
}
exports.handleAccept = handleAccept;
//# sourceMappingURL=accept.js.map

2
packages/endpoints/lib/inbox/sideEffects/accept.js.map
View File

@ -1 +1 @@
{"version":3,"file":"accept.js","sourceRoot":"","sources":["../../../src/inbox/sideEffects/accept.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,iEAOsC;AACtC,wDAA0C;AAC1C,uDAAgD;AAIzC,KAAK,UAAU,YAAY,CAEhC,QAAmB,EACnB,SAAmB;IAEnB,IAAA,+BAAc,EAAY,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;IAE7D,MAAM,QAAQ,GAAG,IAAA,iBAAK,EAAC,QAAQ,CAAC,MAAM,CAAC,CAAC;IAExC,IAAA,6BAAY,EAAC,QAAQ,CAAC,CAAC;IAEvB,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,CAAC;IAEnD,IAAA,iCAAgB,EAAC,MAAM,CAAC,CAAC;IAEzB,IAAI,CAAC,IAAA,uBAAM,EAAY,MAAM,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;QACvD,OAAO;KACR;IAED,MAAM,cAAc,GAAG,MAAM,CAAC;IAE9B,IAAA,+BAAc,EAAY,cAAc,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;IAEnE,MAAM,UAAU,GAAG,IAAA,iBAAK,EAAC,cAAc,CAAC,KAAK,CAAC,CAAC;IAE/C,IAAA,6BAAY,EAAC,UAAU,CAAC,CAAC;IAEzB,IAAI,UAAU,CAAC,QAAQ,EAAE,KAAK,IAAA,iBAAK,EAAC,SAAS,CAAC,EAAE,QAAQ,EAAE,EAAE;QAE1D,OAAO;KACR;IAED,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;IAEvD,IAAA,gCAAe,EAAC,QAAQ,CAAC,CAAC;IAE1B,MAAM,UAAU,GAAG,IAAA,iBAAK,EAAC,cAAc,CAAC,MAAM,CAAC,CAAC;IAEhD,IAAA,6BAAY,EAAC,UAAU,CAAC,CAAC;IAEzB,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;IAEvD,IAAA,gCAAe,EAAC,QAAQ,CAAC,CAAC;IAE1B,MAAM,WAAW,GAAG,IAAA,iBAAK,EAAC,QAAQ,CAAC,SAAS,CAAC,CAAC;IAE9C,IAAA,6BAAY,EAAC,WAAW,CAAC,CAAC;IAE1B,MAAM,SAAS,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC;IAEzD,IAAA,+BAAc,EAAgB,SAAS,EAAE,EAAE,CAAC,eAAe,CAAC,UAAU,CAAC,CAAC;IACxE,IAAA,8BAAa,EAAC,SAAS,CAAC,KAAK,CAAC,CAAC;IAG/B,IACE,SAAS,CAAC,KAAK;SACZ,GAAG,CAAC,CAAC,IAAwB,EAAE,EAAE,CAAC,IAAA,iBAAK,EAAC,IAAI,CAAC,EAAE,QAAQ,EAAE,CAAC;SAC1D,QAAQ,CAAC,UAAU,CAAC,QAAQ,EAAE,CAAC,EAClC;QACA,OAAO,CAAC,GAAG,CAAC,oBAAoB,CAAC,CAAC;QAClC,OAAO;KACR;IAED,MAAM,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,WAAW,EAAE,UAAU,CAAC,CAAC;AACtD,CAAC;AAhED,oCAgEC"}
{"version":3,"file":"accept.js","sourceRoot":"","sources":["../../../src/inbox/sideEffects/accept.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,iEAOsC;AACtC,wDAA0C;AAC1C,uDAAgD;AAIzC,KAAK,UAAU,YAAY,CAEhC,QAAmB,EACnB,SAAmB;IAEnB,IAAA,+BAAc,EAAY,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;IAE7D,MAAM,QAAQ,GAAG,IAAA,iBAAK,EAAC,QAAQ,CAAC,MAAM,CAAC,CAAC;IAExC,IAAA,6BAAY,EAAC,QAAQ,CAAC,CAAC;IAEvB,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,CAAC;IAEnD,IAAA,iCAAgB,EAAC,MAAM,CAAC,CAAC;IAEzB,IAAI,CAAC,IAAA,uBAAM,EAAY,MAAM,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;QACvD,OAAO;KACR;IAED,MAAM,cAAc,GAAG,MAAM,CAAC;IAE9B,IAAA,+BAAc,EAAY,cAAc,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;IAEnE,MAAM,UAAU,GAAG,IAAA,iBAAK,EAAC,cAAc,CAAC,KAAK,CAAC,CAAC;IAE/C,IAAA,6BAAY,EAAC,UAAU,CAAC,CAAC;IAEzB,IAAI,UAAU,CAAC,QAAQ,EAAE,KAAK,IAAA,iBAAK,EAAC,SAAS,CAAC,EAAE,QAAQ,EAAE,EAAE;QAE1D,OAAO;KACR;IAED,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;IAEvD,IAAA,gCAAe,EAAC,QAAQ,CAAC,CAAC;IAE1B,MAAM,UAAU,GAAG,IAAA,iBAAK,EAAC,cAAc,CAAC,MAAM,CAAC,CAAC;IAEhD,IAAA,6BAAY,EAAC,UAAU,CAAC,CAAC;IAEzB,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;IAEvD,IAAA,gCAAe,EAAC,QAAQ,CAAC,CAAC;IAE1B,MAAM,WAAW,GAAG,IAAA,iBAAK,EAAC,QAAQ,CAAC,SAAS,CAAC,CAAC;IAE9C,IAAA,6BAAY,EAAC,WAAW,CAAC,CAAC;IAE1B,MAAM,SAAS,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC;IAEzD,IAAA,+BAAc,EAAgB,SAAS,EAAE,EAAE,CAAC,eAAe,CAAC,UAAU,CAAC,CAAC;IACxE,IAAA,8BAAa,EAAC,SAAS,CAAC,KAAK,CAAC,CAAC;IAG/B,IACE,SAAS,CAAC,KAAK;SACZ,GAAG,CAAC,CAAC,IAAwB,EAAE,EAAE,CAAC,IAAA,iBAAK,EAAC,IAAI,CAAC,EAAE,QAAQ,EAAE,CAAC;SAC1D,QAAQ,CAAC,UAAU,CAAC,QAAQ,EAAE,CAAC,EAClC;QACA,OAAO,CAAC,GAAG,CAAC,oBAAoB,CAAC,CAAC;QAClC,OAAO;KACR;IAED,MAAM,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,WAAW,EAAE,UAAU,CAAC,CAAC;IAEpD,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,eAAe,CAAC,QAAQ,EAAE,UAAU,CAAC,CAAC;IACvE,MAAM,UAAU,GAAG,IAAA,iBAAK,EAAC,QAAQ,CAAC,CAAC;IAEnC,MAAM,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,UAAU,EAAE,IAAA,iBAAK,EAAC,cAAc,CAAC,CAAC,CAAC;AAChE,CAAC;AArED,oCAqEC"}

2
packages/endpoints/lib/outbox/index.d.ts vendored
View File

@ -17,6 +17,7 @@ import { handleBlock } from './sideEffects/block';
import { handleAdd } from './sideEffects/add';
import { handleUndo } from './sideEffects/undo';
import { handleRemove } from './sideEffects/remove';
import { handleFollow } from './sideEffects/follow';
import { handleUndoBlock } from './sideEffects/undo/undoBlock';
import { handleUndoFollow } from './sideEffects/undo/undoFollow';
import { handleUndoAccept } from './sideEffects/undo/undoAccept';
@ -52,6 +53,7 @@ export declare class OutboxPostEndpoint {
protected handleLike: typeof handleLike;
protected handleRemove: typeof handleRemove;
protected handleUpdate: typeof handleUpdate;
protected handleFollow: typeof handleFollow;
protected handleUndo: typeof handleUndo;
protected handleUndoLike: typeof handleUndoLike;
protected handleUndoFollow: typeof handleUndoFollow;

2
packages/endpoints/lib/outbox/index.js
View File

@ -18,6 +18,7 @@ const block_1 = require("./sideEffects/block");
const add_1 = require("./sideEffects/add");
const undo_1 = require("./sideEffects/undo");
const remove_1 = require("./sideEffects/remove");
const follow_1 = require("./sideEffects/follow");
const undoBlock_1 = require("./sideEffects/undo/undoBlock");
const undoFollow_1 = require("./sideEffects/undo/undoFollow");
const undoAccept_1 = require("./sideEffects/undo/undoAccept");
@ -55,6 +56,7 @@ class OutboxPostEndpoint {
handleLike = like_1.handleLike;
handleRemove = remove_1.handleRemove;
handleUpdate = update_1.handleUpdate;
handleFollow = follow_1.handleFollow;
handleUndo = undo_1.handleUndo;
handleUndoLike = undoLike_1.handleUndoLike;
handleUndoFollow = undoFollow_1.handleUndoFollow;

2
packages/endpoints/lib/outbox/index.js.map
View File

@ -1 +1 @@
{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/outbox/index.ts"],"names":[],"mappings":";;;AACA,uDAA8D;AAE9D,qDAAkD;AAClD,qDAAkD;AAClD,yDAAsD;AACtD,iDAA8C;AAC9C,yCAAsC;AACtC,uCAAoC;AACpC,iDAAoD;AACpD,iDAAoD;AACpD,iDAAoD;AACpD,6CAAgD;AAChD,qDAAwD;AACxD,iDAAoD;AACpD,+CAAkD;AAClD,2CAA8C;AAC9C,6CAAgD;AAChD,iDAAoD;AACpD,4DAA+D;AAC/D,8DAAiE;AACjE,8DAAiE;AACjE,0DAA6D;AAC7D,kEAAqE;AAErE,MAAa,kBAAkB;IAUlB;IATX,IAAI,CAA0B;IAC9B,GAAG,CAAM;IACT,MAAM,CAAS;IACf,OAAO,CAAY;IACnB,KAAK,CAAW;IAEhB,QAAQ,GAAqB,IAAI,CAAC;IAElC,YACW,IAAiB,EAC1B,OAMC;QAPQ,SAAI,GAAJ,IAAI,CAAa;QAS1B,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC;QAC3B,IAAI,CAAC,IAAI,GAAG,IAAA,+BAAmB,EAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC9C,IAAI,CAAC,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;QACvB,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;QAC7B,IAAI,CAAC,OAAO,GAAG,OAAO,CAAC,OAAO,IAAI,EAAE,CAAC;IACvC,CAAC;IAES,QAAQ,GAAG,mBAAQ,CAAC;IACpB,cAAc,GAAG,+BAAc,CAAC;IAChC,YAAY,GAAG,2BAAY,CAAC;IAC5B,cAAc,GAAG,+BAAc,CAAC;IAChC,gBAAgB,GAAG,mCAAgB,CAAC;IACvC,OAAO,GAAG,iBAAO,CAAC;IAEf,SAAS,GAAG,eAAS,CAAC;IACtB,cAAc,GAAG,yBAAc,CAAC;IAChC,YAAY,GAAG,qBAAY,CAAC;IAC5B,WAAW,GAAG,mBAAW,CAAC;IAC1B,YAAY,GAAG,qBAAY,CAAC;IAC5B,YAAY,GAAG,qBAAY,CAAC;IAC5B,UAAU,GAAG,iBAAU,CAAC;IACxB,YAAY,GAAG,qBAAY,CAAC;IAC5B,YAAY,GAAG,qBAAY,CAAC;IAE5B,UAAU,GAAG,iBAAU,CAAC;IACxB,cAAc,GAAG,yBAAc,CAAC;IAChC,gBAAgB,GAAG,6BAAgB,CAAC;IACpC,gBAAgB,GAAG,6BAAgB,CAAC;IACpC,kBAAkB,GAAG,iCAAkB,CAAC;IACxC,eAAe,GAAG,2BAAe,CAAC;CAC7C;AAlDD,gDAkDC"}
{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/outbox/index.ts"],"names":[],"mappings":";;;AACA,uDAA8D;AAE9D,qDAAkD;AAClD,qDAAkD;AAClD,yDAAsD;AACtD,iDAA8C;AAC9C,yCAAsC;AACtC,uCAAoC;AACpC,iDAAoD;AACpD,iDAAoD;AACpD,iDAAoD;AACpD,6CAAgD;AAChD,qDAAwD;AACxD,iDAAoD;AACpD,+CAAkD;AAClD,2CAA8C;AAC9C,6CAAgD;AAChD,iDAAoD;AACpD,iDAAoD;AACpD,4DAA+D;AAC/D,8DAAiE;AACjE,8DAAiE;AACjE,0DAA6D;AAC7D,kEAAqE;AAErE,MAAa,kBAAkB;IAUlB;IATX,IAAI,CAA0B;IAC9B,GAAG,CAAM;IACT,MAAM,CAAS;IACf,OAAO,CAAY;IACnB,KAAK,CAAW;IAEhB,QAAQ,GAAqB,IAAI,CAAC;IAElC,YACW,IAAiB,EAC1B,OAMC;QAPQ,SAAI,GAAJ,IAAI,CAAa;QAS1B,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC;QAC3B,IAAI,CAAC,IAAI,GAAG,IAAA,+BAAmB,EAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAC9C,IAAI,CAAC,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC;QACvB,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;QAC7B,IAAI,CAAC,OAAO,GAAG,OAAO,CAAC,OAAO,IAAI,EAAE,CAAC;IACvC,CAAC;IAES,QAAQ,GAAG,mBAAQ,CAAC;IACpB,cAAc,GAAG,+BAAc,CAAC;IAChC,YAAY,GAAG,2BAAY,CAAC;IAC5B,cAAc,GAAG,+BAAc,CAAC;IAChC,gBAAgB,GAAG,mCAAgB,CAAC;IACvC,OAAO,GAAG,iBAAO,CAAC;IAEf,SAAS,GAAG,eAAS,CAAC;IACtB,cAAc,GAAG,yBAAc,CAAC;IAChC,YAAY,GAAG,qBAAY,CAAC;IAC5B,WAAW,GAAG,mBAAW,CAAC;IAC1B,YAAY,GAAG,qBAAY,CAAC;IAC5B,YAAY,GAAG,qBAAY,CAAC;IAC5B,UAAU,GAAG,iBAAU,CAAC;IACxB,YAAY,GAAG,qBAAY,CAAC;IAC5B,YAAY,GAAG,qBAAY,CAAC;IAC5B,YAAY,GAAG,qBAAY,CAAC;IAE5B,UAAU,GAAG,iBAAU,CAAC;IACxB,cAAc,GAAG,yBAAc,CAAC;IAChC,gBAAgB,GAAG,6BAAgB,CAAC;IACpC,gBAAgB,GAAG,6BAAgB,CAAC;IACpC,kBAAkB,GAAG,iCAAkB,CAAC;IACxC,eAAe,GAAG,2BAAe,CAAC;CAC7C;AAnDD,gDAmDC"}

3
packages/endpoints/lib/outbox/runSideEffects.js
View File

@ -55,6 +55,9 @@ async function runSideEffects() {
if ((0, type_utilities_1.isType)(this.activity, AP.ActivityTypes.REMOVE)) {
await this.handleRemove(this.activity);
}
if ((0, type_utilities_1.isType)(this.activity, AP.ActivityTypes.FOLLOW)) {
await this.handleFollow(this.activity);
}
if ((0, type_utilities_1.isType)(this.activity, AP.ActivityTypes.UNDO)) {
await this.handleUndo(this.activity);
}

2
packages/endpoints/lib/outbox/runSideEffects.js.map
View File

@ -1 +1 @@
{"version":3,"file":"runSideEffects.js","sourceRoot":"","sources":["../../src/outbox/runSideEffects.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,wDAA0C;AAC1C,iEAAsD;AAG/C,KAAK,UAAU,cAAc;IAClC,IAAI;QACF,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAW,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,KAAK,CAAC,EAAE;YAC3D,MAAM,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACvC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAU,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,IAAI,CAAC,EAAE;YACzD,MAAM,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACtC;QAED,IAAI,IAAA,uBAAM,EAAc,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,QAAQ,CAAC,EAAE;YACjE,MAAM,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SAC1C;QAED,IAAI,IAAA,uBAAM,EAAS,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,GAAG,CAAC,EAAE;YACvD,MAAM,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACrC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAU,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,IAAI,CAAC,EAAE;YACzD,MAAM,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACtC;KACF;IAAC,OAAO,KAAK,EAAE;QACd,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;KACpB;IAED,KAAK,MAAM,MAAM,IAAI,IAAI,CAAC,OAAO,EAAE;QACjC,IAAI,MAAM,CAAC,sBAAsB,EAAE;YACjC,IAAI;gBACF,MAAM,MAAM,CAAC,sBAAsB,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAChD;YAAC,OAAO,KAAK,EAAE;gBACd,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;aACpB;SACF;KACF;AACH,CAAC;AAtDD,wCAsDC"}
{"version":3,"file":"runSideEffects.js","sourceRoot":"","sources":["../../src/outbox/runSideEffects.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,wDAA0C;AAC1C,iEAAsD;AAG/C,KAAK,UAAU,cAAc;IAClC,IAAI;QACF,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAW,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,KAAK,CAAC,EAAE;YAC3D,MAAM,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACvC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAU,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,IAAI,CAAC,EAAE;YACzD,MAAM,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACtC;QAED,IAAI,IAAA,uBAAM,EAAc,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,QAAQ,CAAC,EAAE;YACjE,MAAM,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SAC1C;QAED,IAAI,IAAA,uBAAM,EAAS,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,GAAG,CAAC,EAAE;YACvD,MAAM,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACrC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAY,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;YAC7D,MAAM,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACxC;QAED,IAAI,IAAA,uBAAM,EAAU,IAAI,CAAC,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,IAAI,CAAC,EAAE;YACzD,MAAM,IAAI,CAAC,UAAU,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;SACtC;KACF;IAAC,OAAO,KAAK,EAAE;QACd,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;KACpB;IAED,KAAK,MAAM,MAAM,IAAI,IAAI,CAAC,OAAO,EAAE;QACjC,IAAI,MAAM,CAAC,sBAAsB,EAAE;YACjC,IAAI;gBACF,MAAM,MAAM,CAAC,sBAAsB,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAChD;YAAC,OAAO,KAAK,EAAE;gBACd,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;aACpB;SACF;KACF;AACH,CAAC;AA1DD,wCA0DC"}

3
packages/endpoints/lib/outbox/sideEffects/follow.d.ts vendored Normal file
View File

@ -0,0 +1,3 @@
import { OutboxPostEndpoint } from '..';
import * as AP from '@activity-kit/types';
export declare function handleFollow(this: OutboxPostEndpoint, activity: AP.Entity): Promise<void>;

44
packages/endpoints/lib/outbox/sideEffects/follow.js Normal file
View File

@ -0,0 +1,44 @@
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.handleFollow = void 0;
const AP = __importStar(require("@activity-kit/types"));
const type_utilities_1 = require("@activity-kit/type-utilities");
const utilities_1 = require("@activity-kit/utilities");
async function handleFollow(activity) {
(0, type_utilities_1.assertIsApType)(activity, AP.ActivityTypes.FOLLOW);
const objectId = (0, utilities_1.getId)(activity.object);
(0, type_utilities_1.assertExists)(objectId);
const object = await this.core.findEntityById(objectId);
(0, type_utilities_1.assertIsApEntity)(object);
const actorId = (0, utilities_1.getId)(activity.actor);
const actor = await this.core.queryById(actorId);
(0, type_utilities_1.assertIsApActor)(actor);
const requests = await this.core.getStreamByName(actor, 'Requests');
const requestsId = (0, utilities_1.getId)(requests);
await this.core.insertItem(requestsId, (0, utilities_1.getId)(activity));
}
exports.handleFollow = handleFollow;
//# sourceMappingURL=follow.js.map

1
packages/endpoints/lib/outbox/sideEffects/follow.js.map Normal file
View File

@ -0,0 +1 @@
{"version":3,"file":"follow.js","sourceRoot":"","sources":["../../../src/outbox/sideEffects/follow.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AACA,wDAA0C;AAC1C,iEAKsC;AACtC,uDAAgD;AAEzC,KAAK,UAAU,YAAY,CAEhC,QAAmB;IAEnB,IAAA,+BAAc,EAAY,QAAQ,EAAE,EAAE,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;IAE7D,MAAM,QAAQ,GAAG,IAAA,iBAAK,EAAC,QAAQ,CAAC,MAAM,CAAC,CAAC;IAExC,IAAA,6BAAY,EAAC,QAAQ,CAAC,CAAC;IAEvB,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,cAAc,CAAC,QAAQ,CAAC,CAAC;IAExD,IAAA,iCAAgB,EAAC,MAAM,CAAC,CAAC;IAEzB,MAAM,OAAO,GAAG,IAAA,iBAAK,EAAC,QAAQ,CAAC,KAAK,CAAC,CAAC;IAEtC,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC;IAEjD,IAAA,gCAAe,EAAC,KAAK,CAAC,CAAC;IAEvB,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,eAAe,CAAC,KAAK,EAAE,UAAU,CAAC,CAAC;IACpE,MAAM,UAAU,GAAG,IAAA,iBAAK,EAAC,QAAQ,CAAC,CAAC;IAEnC,MAAM,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,UAAU,EAAE,IAAA,iBAAK,EAAC,QAAQ,CAAC,CAAC,CAAC;AAC1D,CAAC;AAxBD,oCAwBC"}

5
packages/endpoints/src/inbox/sideEffects/accept.ts
View File

@ -75,4 +75,9 @@ export async function handleAccept(
}
await this.core.insertItem(followingId, followeeId);
const requests = await this.core.getStreamByName(follower, 'Requests');
const requestsId = getId(requests);
await this.core.removeItem(requestsId, getId(followActivity));
}

2
packages/endpoints/src/outbox/index.ts
View File

@ -17,6 +17,7 @@ import { handleBlock } from './sideEffects/block';
import { handleAdd } from './sideEffects/add';
import { handleUndo } from './sideEffects/undo';
import { handleRemove } from './sideEffects/remove';
import { handleFollow } from './sideEffects/follow';
import { handleUndoBlock } from './sideEffects/undo/undoBlock';
import { handleUndoFollow } from './sideEffects/undo/undoFollow';
import { handleUndoAccept } from './sideEffects/undo/undoAccept';
@ -66,6 +67,7 @@ export class OutboxPostEndpoint {
protected handleLike = handleLike;
protected handleRemove = handleRemove;
protected handleUpdate = handleUpdate;
protected handleFollow = handleFollow;
protected handleUndo = handleUndo;
protected handleUndoLike = handleUndoLike;

4
packages/endpoints/src/outbox/runSideEffects.ts
View File

@ -40,6 +40,10 @@ export async function runSideEffects(this: OutboxPostEndpoint) {
await this.handleRemove(this.activity);
}
if (isType<AP.Follow>(this.activity, AP.ActivityTypes.FOLLOW)) {
await this.handleFollow(this.activity);
}
if (isType<AP.Undo>(this.activity, AP.ActivityTypes.UNDO)) {
await this.handleUndo(this.activity);
}

35
packages/endpoints/src/outbox/sideEffects/follow.ts Normal file
View File

@ -0,0 +1,35 @@
import { OutboxPostEndpoint } from '..';
import * as AP from '@activity-kit/types';
import {
assertExists,
assertIsApActor,
assertIsApEntity,
assertIsApType,
} from '@activity-kit/type-utilities';
import { getId } from '@activity-kit/utilities';
export async function handleFollow(
this: OutboxPostEndpoint,
activity: AP.Entity,
) {
assertIsApType<AP.Follow>(activity, AP.ActivityTypes.FOLLOW);
const objectId = getId(activity.object);
assertExists(objectId);
const object = await this.core.findEntityById(objectId);
assertIsApEntity(object);
const actorId = getId(activity.actor);
const actor = await this.core.queryById(actorId);
assertIsApActor(actor);
const requests = await this.core.getStreamByName(actor, 'Requests');
const requestsId = getId(requests);
await this.core.insertItem(requestsId, getId(activity));
}