filecoin-project/slate
1
1
Fork 0
mirror of https://github.com/filecoin-project/slate.git synced 2024-12-25 18:13:10 +03:00
Code Issues Packages Projects Releases Wiki Activity

createSlateActivityForEachSubscriber, createSlateObjectActivityForEachSubscriber

Browse Source
This commit is contained in:
@wwwjim 2020-11-26 00:00:33 -08:00
parent 4bc664f2a0
commit 04d0ca5b72
1 changed files with 46 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
node_common/monitor.js
View File

@ -45,6 +45,27 @@ export const createUser = ({ userId, data }) => {
} }
}; };
const createSlateActivityForEachSubscriber = async ({ userId, data }) => {
const subscriptions = await Data.getSubscriptionsToUserId({ userId });
if (subscriptions.length) {
for (let i = 0; i < subscriptions.length; i++) {
const s = subscriptions[i];
// NOTE(jim):
// <USER> CREATED <SLATE>
Data.createActivity({
userId: s.owner_user_id,
data: {
type: "ANOTHER_USER_CREATED_SLATE",
actorUserId: data.actorUserId,
context: data.context,
},
});
}
}
};
export const createSlate = ({ userId, data }) => { export const createSlate = ({ userId, data }) => {
try { try {
Data.createOrUpdateStats(new Date(), { slates: 1 }); Data.createOrUpdateStats(new Date(), { slates: 1 });
@ -56,9 +77,9 @@ export const createSlate = ({ userId, data }) => {
data: { type: "CREATE_SLATE", actorUserId: data.actorUserId, context: data.context }, data: { type: "CREATE_SLATE", actorUserId: data.actorUserId, context: data.context },
}); });
// TODO(JIM): // NOTE(JIM):
// <VIEWER> WITNESSES <USER> CREATING <SLATE> // <VIEWER> WITNESSES <USER> CREATING <SLATE>
// -- createSlateActivityForEachSubscriber({ userId, data });
const userProfileURL = `https://slate.host/${data.context.username}`; const userProfileURL = `https://slate.host/${data.context.username}`;
const userURL = `<${userProfileURL}|${data.context.username}>`; const userURL = `<${userProfileURL}|${data.context.username}>`;
@ -72,6 +93,27 @@ export const createSlate = ({ userId, data }) => {
} }
}; };
const createSlateObjectActivityForEachSubscriber = async ({ slateId, data }) => {
const subscriptions = await Data.getSubscriptionsToSlateId({ slateId });
if (subscriptions.length) {
for (let i = 0; i < subscriptions.length; i++) {
const s = subscriptions[i];
// NOTE(jim):
// <VIEWER> WITNESS <USER> ADDED OBJECT TO <SLATE>
Data.createActivity({
userId: s.owner_user_id,
data: {
type: "ANOTHER_USER_CREATE_SLATE_OBJECT",
actorUserId: data.actorUserId,
context: data.context,
},
});
}
}
};
export const createSlateObject = ({ slateId, data }) => { export const createSlateObject = ({ slateId, data }) => {
Data.createOrUpdateStats(new Date(), { objects: 1 }); Data.createOrUpdateStats(new Date(), { objects: 1 });
@ -92,9 +134,9 @@ export const createSlateObject = ({ slateId, data }) => {
}, },
}); });
// TODO(jim): // NOTE(jim):
// <VIEWER> WITNESS <USER> ADDED OBJECT TO <SLATE> // <VIEWER> WITNESS <USER> ADDED OBJECT TO <SLATE>
// -- createSlateObjectActivityForEachSubscriber({ slateId, data });
const userProfileURL = `https://slate.host/${data.context.username}`; const userProfileURL = `https://slate.host/${data.context.username}`;
const userURL = `<${userProfileURL}|${data.context.username}>`; const userURL = `<${userProfileURL}|${data.context.username}>`;