131 lines
3.6 KiB
JavaScript
131 lines
3.6 KiB
JavaScript
const { localActorId } = require('./util');
|
|
const {
|
|
ActivityStreamMediaType,
|
|
WellKnownActivityTypes,
|
|
WellKnownActivity,
|
|
WellKnownRecipientFields,
|
|
HttpSignatureSignHeaders,
|
|
} = require('./const');
|
|
const ActivityPubObject = require('./object');
|
|
const { Errors } = require('../enig_error');
|
|
const UserProps = require('../user_property');
|
|
const { postJson } = require('../http_util');
|
|
const { getISOTimestampString } = require('../database');
|
|
|
|
// deps
|
|
const _ = require('lodash');
|
|
|
|
module.exports = class Activity extends ActivityPubObject {
|
|
constructor(obj) {
|
|
super(obj);
|
|
}
|
|
|
|
static get ActivityTypes() {
|
|
return WellKnownActivityTypes;
|
|
}
|
|
|
|
static fromJsonString(s) {
|
|
const obj = ActivityPubObject.fromJsonString(s);
|
|
return new Activity(obj);
|
|
}
|
|
|
|
static makeFollow(webServer, localActor, remoteActor) {
|
|
return new Activity({
|
|
id: Activity.activityObjectId(webServer),
|
|
type: WellKnownActivity.Follow,
|
|
actor: localActor,
|
|
object: remoteActor.id,
|
|
});
|
|
}
|
|
|
|
// https://www.w3.org/TR/activitypub/#accept-activity-inbox
|
|
static makeAccept(webServer, localActor, followRequest) {
|
|
return new Activity({
|
|
id: Activity.activityObjectId(webServer),
|
|
type: WellKnownActivity.Accept,
|
|
actor: localActor,
|
|
object: followRequest, // previous request Activity
|
|
});
|
|
}
|
|
|
|
static makeCreate(webServer, actor, obj) {
|
|
const activity = new Activity({
|
|
id: Activity.activityObjectId(webServer),
|
|
to: obj.to,
|
|
type: WellKnownActivity.Create,
|
|
actor,
|
|
object: obj,
|
|
});
|
|
|
|
const copy = n => {
|
|
if (obj[n]) {
|
|
activity[n] = obj[n];
|
|
}
|
|
};
|
|
|
|
copy('to');
|
|
copy('cc');
|
|
// :TODO: Others?
|
|
|
|
return activity;
|
|
}
|
|
|
|
static makeTombstone(obj) {
|
|
const deleted = getISOTimestampString();
|
|
return new Activity({
|
|
id: obj.id,
|
|
type: WellKnownActivity.Tombstone,
|
|
deleted,
|
|
published: deleted,
|
|
updated: deleted,
|
|
});
|
|
}
|
|
|
|
sendTo(inboxEndpoint, fromUser, webServer, cb) {
|
|
const privateKey = fromUser.getProperty(UserProps.PrivateActivityPubSigningKey);
|
|
if (_.isEmpty(privateKey)) {
|
|
return cb(
|
|
Errors.MissingProperty(
|
|
`User "${fromUser.username}" is missing the '${UserProps.PrivateActivityPubSigningKey}' property`
|
|
)
|
|
);
|
|
}
|
|
|
|
const reqOpts = {
|
|
headers: {
|
|
'Content-Type': ActivityStreamMediaType,
|
|
},
|
|
sign: {
|
|
key: privateKey,
|
|
keyId: localActorId(webServer, fromUser) + '#main-key',
|
|
authorizationHeaderName: 'Signature',
|
|
headers: HttpSignatureSignHeaders,
|
|
},
|
|
};
|
|
|
|
const activityJson = JSON.stringify(this);
|
|
return postJson(inboxEndpoint, activityJson, reqOpts, cb);
|
|
}
|
|
|
|
// :TODO: we need dp/support a bit more here...
|
|
recipientIds() {
|
|
const ids = [];
|
|
|
|
WellKnownRecipientFields.forEach(field => {
|
|
let v = this[field];
|
|
if (v) {
|
|
if (!Array.isArray(v)) {
|
|
v = [v];
|
|
}
|
|
ids.push(...v);
|
|
}
|
|
});
|
|
|
|
return Array.from(new Set(ids));
|
|
}
|
|
|
|
static activityObjectId(webServer) {
|
|
return ActivityPubObject.makeObjectId(webServer, 'activity');
|
|
}
|
|
};
|