Class QueueHandler

src/queue/handlers/QueueHandler.ts:21–327

 * @implements {IQueueHandler}
 */
export default class QueueHandler extends BaseHandler implements IQueueHandler {
  /**
   * Create a queue with queueName.
   *
   * @param {Models.QueueCreateOptionalParams} options
   * @param {Context} context
   * @returns {Promise<Models.QueueCreateResponse>}
   * @memberof QueueHandler
   */
  public async create(
    options: Models.QueueCreateOptionalParams,
    context: Context
  ): Promise<Models.QueueCreateResponse> {
    const queueCtx = new QueueStorageContext(context);
    const accountName = queueCtx.account!;
    const queueName = queueCtx.queue!;

    const req = context.request! as any;
    const rawHeaders = req.req.rawHeaders;

    // The same as Azure Storage, should preserve the case of metadata names with them created.
    const metadata = this.parseMetadata(options.metadata, rawHeaders);

    const queue: QueueModel = {
      accountName,
      name: queueName,
      metadata
    };

    const statusCode = await this.metadataStore.createQueue(queue, context);

    const response: Models.QueueCreateResponse = {
      date: context.startTime,
      requestId: queueCtx.contextID,
      statusCode,
      version: QUEUE_API_VERSION,
      clientRequestId: options.requestId
    };

    return response;
  }

  /**
   * Delete a queue according to its name.
   *
   * @param {Models.QueueDeleteMethodOptionalParams} options
   * @param {Context} context
   * @returns {Promise<Models.QueueDeleteResponse>}
   * @memberof QueueHandler
   */
  public async delete(
    options: Models.QueueDeleteMethodOptionalParams,
    context: Context
  ): Promise<Models.QueueDeleteResponse> {
    const queueCtx = new QueueStorageContext(context);
    const accountName = queueCtx.account!;
    const queueName = queueCtx.queue!;