Alessandro Magionami
689bed652d
* chore(activitystream): addStreamUpdatedActivity refactor multi region * chore(activitystream): addStreamAccessRequestedActivity refactor multiregion
50 lines
1.5 KiB
TypeScript
50 lines
1.5 KiB
TypeScript
import { db } from '@/db/knex'
|
|
import {
|
|
AddStreamAccessRequestedActivity,
|
|
SaveActivity
|
|
} from '@/modules/activitystream/domain/operations'
|
|
import { ActionTypes, ResourceTypes } from '@/modules/activitystream/helpers/types'
|
|
import { saveActivityFactory } from '@/modules/activitystream/repositories'
|
|
|
|
/**
|
|
* Save a "stream access requested" activity
|
|
*/
|
|
export const addStreamAccessRequestedActivityFactory =
|
|
({
|
|
saveActivity
|
|
}: {
|
|
saveActivity: SaveActivity
|
|
}): AddStreamAccessRequestedActivity =>
|
|
async (params: { streamId: string; requesterId: string }) => {
|
|
const { streamId, requesterId } = params
|
|
await saveActivity({
|
|
streamId,
|
|
resourceType: ResourceTypes.Stream,
|
|
resourceId: streamId,
|
|
userId: requesterId,
|
|
actionType: ActionTypes.Stream.AccessRequestSent,
|
|
message: `User ${requesterId} has requested access to stream ${streamId}`,
|
|
info: { requesterId }
|
|
})
|
|
}
|
|
|
|
/**
|
|
* Save a "stream acccess request declined/denied" activity
|
|
*/
|
|
export async function addStreamAccessRequestDeclinedActivity(params: {
|
|
streamId: string
|
|
requesterId: string
|
|
declinerId: string
|
|
}) {
|
|
const { streamId, requesterId, declinerId } = params
|
|
await saveActivityFactory({ db })({
|
|
streamId,
|
|
resourceType: ResourceTypes.Stream,
|
|
resourceId: streamId,
|
|
userId: declinerId,
|
|
actionType: ActionTypes.Stream.AccessRequestDeclined,
|
|
message: `User ${declinerId} declined access to stream ${streamId} for user ${requesterId}`,
|
|
info: { requesterId, declinerId }
|
|
})
|
|
}
|