openBackhaul / MicroWaveDeviceInventory

Physical and logical inventory of the MW SDN Domain
Apache License 2.0
5 stars 1 forks source link

[Subscription] Unable to end the subscription in MWDI #989

Open Ziabatcha opened 3 months ago

Ziabatcha commented 3 months ago

In MWDI, while deploring itself API:/v1/notify-attribute-value-changes enabled and allowed to forward the notifcation to subscriber. But when user tried to delete the subscription using "API:/v1/end-subscription", delete is successful in swagger but receiving the failed notification in docker logs for default IP.

Also, it would be helpful how we can know "who are the subscribers from MWDI" Version:1.1.2.e_impl Logs:

[08.07.2024 06:27.11.662] [ERROR] Error: connect ETIMEDOUT 1.1.4.13:4013
    at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1278:16) {
  errno: -110,
  code: 'ETIMEDOUT',
  syscall: 'connect',
  address: '1.1.4.13',
  port: 4013,
  config: {
    url: 'HTTP://1.1.4.13:4013/v1/regard-attribute-value-change',
    method: 'post',
    data: '{"MicroWaveDeviceInventory-1-1:attribute-value-changed-notification":{"counter":40,"timestamp":"2024-07-08T06:17:31.0+00:00","attribute-name":"attribute-name-not-yet-defined","new-value":"SEVERITY_AND_CLEARED_TYPE_CLEARED"}}',
    headers: {
      Accept: 'application/json, text/plain, */*',
      'Content-Type': 'application/json',
      'x-correlator': '6daea1ae-ECbF-fDCe-79eD-f2ED6A7cAFa0',
      'trace-indicator': '1',
      user: 'MicroWaveDeviceInventory',
      originator: 'MicroWaveDeviceInventory',
      'customer-journey': 1,
      'operation-key': 'xxxxxxxxxxxxxxxxxxxxxx',
      'User-Agent': 'axios/0.21.4',
      'Content-Length': 224
    },
    transformRequest: [ [Function: transformRequest] ],
    transformResponse: [ [Function: transformResponse] ],
    timeout: 0,
    adapter: [Function: httpAdapter],
    xsrfCookieName: 'XSRF-TOKEN',
    xsrfHeaderName: 'X-XSRF-TOKEN',
    maxContentLength: -1,
    maxBodyLength: -1,
    validateStatus: [Function: validateStatus],
    transitional: {
      silentJSONParsing: true,
      forcedJSONParsing: true,
      clarifyTimeoutError: false
    }
  },
  request: <ref *1> Writable {
    _writableState: WritableState {
      objectMode: false,
      highWaterMark: 16384,
      finalCalled: false,
      needDrain: false,
      ending: false,
      ended: false,
      finished: false,
      destroyed: false,
      decodeStrings: true,
      defaultEncoding: 'utf8',
      length: 0,
      writing: false,
      corked: 0,
      sync: true,
      bufferProcessing: false,
      onwrite: [Function: bound onwrite],
      writecb: null,
      writelen: 0,
      afterWriteTickInfo: null,
      buffered: [],
      bufferedIndex: 0,
      allBuffers: true,
      allNoop: true,
      pendingcb: 0,
      constructed: true,
      prefinished: false,
      errorEmitted: false,
      emitClose: true,
      autoDestroy: true,
      errored: null,
      closed: false,
      closeEmitted: false,
      [Symbol(kOnFinished)]: []
    },
    _events: [Object: null prototype] {
      response: [Function: handleResponse],
      error: [Function: handleRequestError]
    },
    _eventsCount: 2,
    _maxListeners: undefined,
    _options: {
      maxRedirects: 21,
      maxBodyLength: 10485760,
      protocol: 'http:',
      path: '/v1/regard-attribute-value-change',
      method: 'POST',
      headers: [Object],
      agent: undefined,
      agents: [Object],
      auth: undefined,
      hostname: '1.1.4.13',
      port: '4013',
      nativeProtocols: [Object],
      pathname: '/v1/regard-attribute-value-change'
    },
    _ended: false,
    _ending: true,
    _redirectCount: 0,
    _redirects: [],
    _requestBodyLength: 224,
    _requestBodyBuffers: [ [Object] ],
    _onNativeResponse: [Function (anonymous)],
    _currentRequest: ClientRequest {
      _events: [Object: null prototype],
      _eventsCount: 7,
      _maxListeners: undefined,
      outputData: [],
      outputSize: 0,
      writable: true,
      destroyed: false,
      _last: true,
      chunkedEncoding: false,
      shouldKeepAlive: false,
      maxRequestsOnConnectionReached: false,
      _defaultKeepAlive: true,
      useChunkedEncodingByDefault: true,
      sendDate: false,
      _removedConnection: false,
      _removedContLen: false,
      _removedTE: false,
      strictContentLength: false,
      _contentLength: 224,
      _hasBody: true,
      _trailer: '',
      finished: false,
      _headerSent: true,
      _closed: false,
      socket: [Socket],
      _header: 'POST /v1/regard-attribute-value-change HTTP/1.1\r\n' +
        'Accept: application/json, text/plain, */*\r\n' +
        'Content-Type: application/json\r\n' +
        'x-correlator: 6daea1ae-ECbF-fDCe-79eD-f2ED6A7cAFa0\r\n' +
        'trace-indicator: 1\r\n' +
        'user: MicroWaveDeviceInventory\r\n' +
        'originator: MicroWaveDeviceInventory\r\n' +
        'customer-journey: 1\r\n' +
        'operation-key: xxxxxxxxxxxxxxxxxxxxxxxxxxxxxr\n' +
        'User-Agent: axios/0.21.4\r\n' +
        'Content-Length: 224\r\n' +
        'Host: 1.1.4.13:4013\r\n' +
        'Connection: close\r\n' +
        '\r\n',
      _keepAliveTimeout: 0,
      _onPendingData: [Function: nop],
      agent: [Agent],
      socketPath: undefined,
      method: 'POST',
      maxHeaderSize: undefined,
      insecureHTTPParser: undefined,
      path: '/v1/regard-attribute-value-change',
      _ended: false,
      res: null,
      aborted: false,
      timeoutCb: null,
      upgradeOrConnect: false,
      parser: null,
      maxHeadersCount: null,
      reusedSocket: false,
      host: '1.1.4.13',
      protocol: 'http:',
      _redirectable: [Circular *1],
      [Symbol(kCapture)]: false,
      [Symbol(kBytesWritten)]: 0,
      [Symbol(kEndCalled)]: false,
      [Symbol(kNeedDrain)]: false,
      [Symbol(corked)]: 0,
      [Symbol(kOutHeaders)]: [Object: null prototype],
      [Symbol(kUniqueHeaders)]: null
    },
    _currentUrl: 'http://1.1.4.13:4013/v1/regard-attribute-value-change',
    [Symbol(kCapture)]: false
  },
  response: undefined,
  isAxiosError: true,
  toJSON: [Function: toJSON]
} error during subscriber-notification for /v1/notify-attribute-value-changes - debugId: 'f229955a-bd5b-4cbf-8800-63efaeaa019e'