openreplay/frontend/app/services/spotService.ts

import BaseService from './BaseService';

export interface SpotInfo {
  name: string;
  duration: number;
  comments: SpotComment[];
  mobURL: string;
  videoURL: string;
  createdAt: string;
  userID: number;
}
export interface SpotComment {
  user: string;
  text: string;
  createdAt: string;
}

interface GetSpotResponse {
  spot: SpotInfo;
}

export interface UpdateSpotRequest {
  name?: string;
  /** timestamp of public key expiration */
  keyExpiration?: number;
}

interface AddCommentRequest {
  userName: string;
  comment: string;
}

interface GetSpotsResponse {
  spots: SpotInfo[];
  total: number;
  tenantHasSpots: boolean;
}

interface GetSpotsRequest {
  query?: string;
  filterBy: 'own' | 'all' | 'shared';
  /** @default desc, order by created date */
  order: 'asc' | 'desc';
  page: number;
  limit: number;
}

export default class SpotService extends BaseService {
  async fetchSpots(filters: GetSpotsRequest): Promise<GetSpotsResponse> {
    return this.client
      .get('/spot/v1/spots', filters)
      .then((r) => r.json())
      .catch(console.error);
  }

  async fetchSpot(id: string, accessKey?: string): Promise<GetSpotResponse> {
    return this.client
      .get(`/spot/v1/spots/${id}${accessKey ? `?key=${accessKey}` : ''}`)
      .then((r) => r.json());
  }

  async updateSpot(id: string, filter: UpdateSpotRequest) {
    return this.client
      .patch(`/spot/v1/spots/${id}`, filter)
      .then((r) => r.json())
      .catch(console.error);
  }

  async deleteSpot(spotIDs: string[]) {
    return this.client
      .delete('/spot/v1/spots', {
        spotIDs,
      })
      .then((r) => r.json())
      .catch(console.error);
  }

  async addComment(id: string, data: AddCommentRequest, accessKey?: string) {
    return this.client
      .post(
        `/spot/v1/spots/${id}/comment${accessKey ? `?key=${accessKey}` : ''}`,
        data,
      )
      .then((r) => r.json());
  }

  async getVideo(id: string) {
    return this.client
      .get(`/spot/v1/spots/${id}/video`)
      .then((r) => r.json())
      .catch(console.error);
  }

  /**
   * @param id - spot id string
   * @param expiration - in seconds, 0 if removing
   * */
  async generateKey(
    id: string,
    expiration: number,
  ): Promise<{ key: { value: string; expiration: number } }> {
    return this.client
      .patch(`/spot/v1/spots/${id}/public-key`, { expiration })
      .then((r) => r.json())
      .catch(console.error);
  }

  async getKey(
    id: string,
  ): Promise<{ key: { value: string; expiration: number } }> {
    return this.client
      .get(`/spot/v1/spots/${id}/public-key`)
      .then((r) => r.json())
      .catch(console.error);
  }

  async checkProcessingStatus(id: string, accessKey?: string) {
    return this.client
      .get(`/spot/v1/spots/${id}/status${accessKey ? `?key=${accessKey}` : ''}`)
      .then((r) => r.json())
      .catch(console.error);
  }
}