flexor-api/src/lib/media.ts

import { Container } from '@azure/cosmos'
import { BlockBlobURL, SharedKeyCredential, Aborter, ContainerSASPermissions, generateBlobSASQueryParameters, AnonymousCredential } from '@azure/storage-blob'
import moment from 'moment'

import { MEDIA_PARTITION_KEY } from '../constants'
import { Media } from '../types/collections'

export function generateSAS(permissions: string, expirationMinutes: number) {
    const sharedKeyCredential = new SharedKeyCredential(process.env.BLOB_STORAGE_ACCOUNT!, process.env.BLOB_STORAGE_ACCOUNT_KEY!)

    return generateBlobSASQueryParameters({
        containerName: process.env.BLOB_STORAGE_CONTAINER!,
        permissions: ContainerSASPermissions.parse(permissions).toString(),
        startTime: new Date(),
        expiryTime: moment().add(expirationMinutes, 'm').toDate(),
    }, sharedKeyCredential).toString()
}

export async function deleteMedia(name: string) {
    const blockBlobURL = new BlockBlobURL(
        `https://${process.env.BLOB_STORAGE_ACCOUNT!}.blob.core.windows.net/${process.env.BLOB_STORAGE_CONTAINER!}/${name}`,
        BlockBlobURL.newPipeline(new SharedKeyCredential(process.env.BLOB_STORAGE_ACCOUNT!, process.env.BLOB_STORAGE_ACCOUNT_KEY!))
    )

    try {
        await blockBlobURL.delete(Aborter.none)
    } catch (e) {
        
    }
}

export async function attachMedia(container: Container, name: string) {
    const mediaItem = container.item(name, MEDIA_PARTITION_KEY)
    const { resource: media } = await mediaItem.read<Media>()

    await mediaItem.replace<Media>({
        ...media,
        attached: true,
    })
}