123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106 |
- // Copyright 2019 Google LLC
- //
- // Licensed under the Apache License, Version 2.0 (the "License");
- // you may not use this file except in compliance with the License.
- // You may obtain a copy of the License at
- //
- // http://www.apache.org/licenses/LICENSE-2.0
- //
- // Unless required by applicable law or agreed to in writing, software
- // distributed under the License is distributed on an "AS IS" BASIS,
- // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- // See the License for the specific language governing permissions and
- // limitations under the License.
- import { ServiceObject, util } from './nodejs-common/index.js';
- import { promisifyAll } from '@google-cloud/promisify';
- /**
- * Create a channel object to interact with a Cloud Storage channel.
- *
- * See {@link https://cloud.google.com/storage/docs/object-change-notification| Object Change Notification}
- *
- * @class
- *
- * @param {string} id The ID of the channel.
- * @param {string} resourceId The resource ID of the channel.
- *
- * @example
- * ```
- * const {Storage} = require('@google-cloud/storage');
- * const storage = new Storage();
- * const channel = storage.channel('id', 'resource-id');
- * ```
- */
- class Channel extends ServiceObject {
- constructor(storage, id, resourceId) {
- const config = {
- parent: storage,
- baseUrl: '/channels',
- // An ID shouldn't be included in the API requests.
- // RE:
- // https://github.com/GoogleCloudPlatform/google-cloud-node/issues/1145
- id: '',
- methods: {
- // Only need `request`.
- },
- };
- super(config);
- this.metadata.id = id;
- this.metadata.resourceId = resourceId;
- }
- /**
- * @typedef {array} StopResponse
- * @property {object} 0 The full API response.
- */
- /**
- * @callback StopCallback
- * @param {?Error} err Request error, if any.
- * @param {object} apiResponse The full API response.
- */
- /**
- * Stop this channel.
- *
- * @param {StopCallback} [callback] Callback function.
- * @returns {Promise<StopResponse>}
- *
- * @example
- * ```
- * const {Storage} = require('@google-cloud/storage');
- * const storage = new Storage();
- * const channel = storage.channel('id', 'resource-id');
- * channel.stop(function(err, apiResponse) {
- * if (!err) {
- * // Channel stopped successfully.
- * }
- * });
- *
- * //-
- * // If the callback is omitted, we'll return a Promise.
- * //-
- * channel.stop().then(function(data) {
- * const apiResponse = data[0];
- * });
- * ```
- */
- stop(callback) {
- callback = callback || util.noop;
- this.request({
- method: 'POST',
- uri: '/stop',
- json: this.metadata,
- }, (err, apiResponse) => {
- callback(err, apiResponse);
- });
- }
- }
- /*! Developer Documentation
- *
- * All async methods (except for streams) will return a Promise in the event
- * that a callback is omitted.
- */
- promisifyAll(Channel);
- /**
- * Reference to the {@link Channel} class.
- * @name module:@google-cloud/storage.Channel
- * @see Channel
- */
- export { Channel };
|