在云端功能上创建消息传递主题

Question

我正在尝试为每个新创建的组创建主题。所以我写了这个函数来做这个操作。

exports.createGroupTopic = functions.database.ref("groups/{groupid}/id") 
       .onWrite(event=>{ 
        var groupid = event.params.groupid; 
        request({ 
        url: "https://iid.googleapis.com/iid/v1/my_registration_token/rel/topics/topic_name", 

        headers: { 
         'Content-Type':'application/json', 
         'Content-Length': 0, 
         'Authorization':'my API Key' 
         } 


        }, function (error, response, body){ 
        console.log(response); 
        }); 



       }); 

但是当我运行这段代码，我得到火力地堡控制台上以下响应日志..

IncomingMessage { 
    _readableState: 
    ReadableState { 
    objectMode: false, 
    highWaterMark: 16384, 
    buffer: BufferList { head: null, tail: null, length: 0 }, 
    length: 0, 
    pipes: null, 
    pipesCount: 0, 
    flowing: true, 
    ended: true, 
    endEmitted: true, 
    reading: false, 
    sync: false, 
    needReadable: false, 
    emittedReadable: false, 
    readableListening: false, 
    resumeScheduled: false, 
    defaultEncoding: 'utf8', 
    ranOut: false, 
    awaitDrain: 0, 
    readingMore: false, 
    decoder: null, 
    encoding: null }, 
    readable: false, 
    domain: null, 
    _events: 
    { end: [ [Function: responseOnEnd], [Function] ], 
    close: [ [Function], [Function] ], 
    data: [Function], 
    error: [Function] }, 
    _eventsCount: 4, 
    _maxListeners: undefined, 
    socket: 
    TLSSocket { 
    _tlsOptions: 
     { pipe: null, 
     secureContext: [Object], 
     isServer: false, 
     requestCert: true, 
     rejectUnauthorized: true, 
     session: undefined, 
     NPNProtocols: undefined, 
     ALPNProtocols: undefined, 
     requestOCSP: undefined }, 
    _secureEstablished: true, 
    _securePending: false, 
    _newSessionPending: false, 
    _controlReleased: true, 
    _SNICallback: null, 
    servername: null, 
    npnProtocol: false, 
    alpnProtocol: false, 
    authorized: true, 
    authorizationError: null, 
    encrypted: true, 
    _events: 
     { close: [Object], 
     end: [Object], 
     finish: [Function: onSocketFinish], 
     _socketEnd: [Function: onSocketEnd], 
     secure: [Function], 
     free: [Function: onFree], 
     agentRemove: [Function: onRemove], 
     drain: [Function: ondrain], 
     error: [Function: socketErrorListener], 
     data: [Function: socketOnData] }, 
    _eventsCount: 10, 
    connecting: false, 
    _hadError: false, 
    _handle: null, 
    _parent: null, 
    _host: 'iid.googleapis.com', 
    _readableState: 
     ReadableState { 
     objectMode: false, 
     highWaterMark: 16384, 
     buffer: [Object], 
     length: 0, 
     pipes: null, 
     pipesCount: 0, 
     flowing: true, 
     ended: true, 
     endEmitted: true, 
     reading: false, 
     sync: false, 
     needReadable: false, 
     emittedReadable: false, 
     readableListening: false, 
     resumeScheduled: false, 
     defaultEncoding: 'utf8', 
     ranOut: false, 
     awaitDrain: 0, 
     readingMore: false, 
     decoder: null, 
     encoding: null }, 
    readable: false, 
    domain: null, 
    _maxListeners: undefined, 
    _writableState: 
     WritableState { 
     objectMode: false, 
     highWaterMark: 16384, 
     needDrain: false, 
     ending: true, 
     ended: true, 
     finished: true, 
     decodeStrings: false, 
     defaultEncoding: 'utf8', 
     length: 0, 
     writing: false, 
     corked: 0, 
     sync: false, 
     bufferProcessing: false, 
     onwrite: [Function], 
     writecb: null, 
     writelen: 0, 
     bufferedRequest: null, 
     lastBufferedRequest: null, 
     pendingcb: 0, 
     prefinished: true, 
     errorEmitted: false, 
     bufferedRequestCount: 0, 
     corkedRequestsFree: [Object] }, 
    writable: false, 
    allowHalfOpen: false, 
    destroyed: true, 
    _bytesDispatched: 468, 
    _sockname: null, 
    _pendingData: null, 
    _pendingEncoding: '', 
    server: undefined, 
    _server: null, 
    ssl: null, 
    _requestCert: true, 
    _rejectUnauthorized: true, 
    parser: null, 
    _httpMessage: 
     ClientRequest { 
     domain: null, 
     _events: [Object], 
     _eventsCount: 5, 
     _maxListeners: undefined, 
     output: [], 
     outputEncodings: [], 
     outputCallbacks: [], 
     outputSize: 0, 
     writable: true, 
     _last: true, 
     upgrading: false, 
     chunkedEncoding: false, 
     shouldKeepAlive: false, 
     useChunkedEncodingByDefault: false, 
     sendDate: false, 
     _removedHeader: [Object], 
     _contentLength: 0, 
     _hasBody: true, 
     _trailer: '', 
     finished: true, 
     _headerSent: true, 
     socket: [Circular], 
     connection: [Circular], 
     _header: 'GET /iid/v1/my_token_id/rel/topics/TOPIC_NAME HTTP/1.1\r\nContent-Type: application/json\r\nContent-Length: 0\r\nAuthorization: api_key\r\nhost: iid.googleapis.com\r\nConnection: close\r\n\r\n', 
     _headers: [Object], 
     _headerNames: [Object], 
     _onPendingData: null, 
     agent: [Object], 
     socketPath: undefined, 
     timeout: undefined, 
     method: 'GET', 
     path: '/iid/v1/fphzdEcS_D0:APA91b 

然后我又跑这地方和它给了我无效的令牌错误。然后我测试了令牌以发送直接通知。它的工作完美。

我不知道问题在哪里。 SO需要帮助:(

Answer 1

代码的这种变化对我的作品。我加了POST方法和前缀key=的授权值。试一试，看看它是否适合你。

exports.createGroupTopic = functions.database.ref("groups/{groupid}/id") 
    .onWrite(event => { 
     var groupid = event.params.groupid; 
     request({ 
      method: 'POST', // <= ADDED 
      //          ------------------- device token ------------ 
      url: "https://iid.googleapis.com/iid/v1/cAzme9iGTO4:APA91bE...lRbx1yTei2PNFgTYGUQDUTj/rel/topics/someTopic", 

      headers: { 
       'Content-Type':'application/json', 
       'Content-Length': 0, 
       // Note below. Added: 'key=' 
       //     ----------------- server key -------------------------- 
       'Authorization':'key=AAAAXp8june:APA91bF-Nq9pmQKr...HOES6ugO3_Xf-jV472nfn-sb' 
      } 
     }, function (error, response, body){ 
      console.log('error:', error); 
      console.log('statusCode:', response && response.statusCode); 
     }); 
    }); 

我用。这个功能来确认是否添加了主题订阅返回体内含有地位的设备，包括订阅的主题：

exports.checkGroupTopic = functions.database.ref("groups/check") 
    .onWrite(event => { 
     const token = 'cAzme9iGTO4:APA91bE...lRbx1yTei2PNFgTYGUQDUTj'; 
     const serverKey = 'AAAAXp8june:APA91bF-Nq9pmQKr...HOES6ugO3_Xf-jV472nfn-sb'; 
     request({ 
      method: 'GET', 
      url: `https://iid.googleapis.com/iid/info/${token}?details=true`, 

      headers: { 
       'Content-Type':'application/json', 
       'Content-Length': 0, 
       'Authorization':`key=${serverKey}` 
      } 
     }, function (error, response, body){ 
      console.log('error:', error); 
      console.log('statusCode:', response && response.statusCode); 
      console.log('body:', body); 
     }); 
    });