@ixo/matrixclient-sdk - npm Package Compare versions

Comparing version 0.3.4 to 1.0.0

main/bot/v1beta1.js

+"use strict";
+
+var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
+Object.defineProperty(exports, "__esModule", {
+  value: true
+});
+exports.getConfig = getConfig;
+exports.invite = invite;
+exports.invited = invited;
+var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
+var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
+var _nodeFetch = _interopRequireDefault(require("node-fetch"));
+var _error = require("../utils/error");
+var _validators = require("../utils/validators");
+var _url = require("../utils/url");
+var _v1beta = require("../api/room/v1beta1");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
+function ownKeys(e, r) { var t = Object.keys(e); if (Object.getOwnPropertySymbols) { var o = Object.getOwnPropertySymbols(e); r && (o = o.filter(function (r) { return Object.getOwnPropertyDescriptor(e, r).enumerable; })), t.push.apply(t, o); } return t; }
+function _objectSpread(e) { for (var r = 1; r < arguments.length; r++) { var t = null != arguments[r] ? arguments[r] : {}; r % 2 ? ownKeys(Object(t), !0).forEach(function (r) { (0, _defineProperty2["default"])(e, r, t[r]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(e, Object.getOwnPropertyDescriptors(t)) : ownKeys(Object(t)).forEach(function (r) { Object.defineProperty(e, r, Object.getOwnPropertyDescriptor(t, r)); }); } return e; }
+function invite(_x, _x2, _x3, _x4) {
+  return _invite.apply(this, arguments);
+}
+function _invite() {
+  _invite = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(roomId, botUrl, homeServerUrl, accessToken) {
+    var _powerLevels$state_de, _ref, _powerLevels$users$bo, _powerLevels$users;
+    var config, botUserId, _error$body, message, powerLevels, requiredPowerLevel, currentBotPower, updatedContent, _t;
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.p = _context.n) {
+        case 0:
+          if ((0, _validators.isValidRoomId)(roomId)) {
+            _context.n = 1;
+            break;
+          }
+          throw new Error('Invalid room ID');
+        case 1:
+          _context.n = 2;
+          return getConfig(botUrl);
+        case 2:
+          config = _context.v;
+          botUserId = config.data.bot.userId;
+          _context.p = 3;
+          _context.n = 4;
+          return (0, _v1beta.inviteUser)(roomId, botUserId, homeServerUrl, accessToken);
+        case 4:
+          _context.n = 6;
+          break;
+        case 5:
+          _context.p = 5;
+          _t = _context.v;
+          message = (_t === null || _t === void 0 ? void 0 : _t.message) || (_t === null || _t === void 0 ? void 0 : (_error$body = _t.body) === null || _error$body === void 0 ? void 0 : _error$body.error) || '';
+          if (message.includes('is already in the room')) {
+            _context.n = 6;
+            break;
+          }
+          throw _t;
+        case 6:
+          _context.n = 7;
+          return (0, _v1beta.getPowerLevels)(roomId, homeServerUrl, accessToken);
+        case 7:
+          powerLevels = _context.v;
+          requiredPowerLevel = (_powerLevels$state_de = powerLevels.state_default) !== null && _powerLevels$state_de !== void 0 ? _powerLevels$state_de : 50;
+          currentBotPower = (_ref = (_powerLevels$users$bo = (_powerLevels$users = powerLevels.users) === null || _powerLevels$users === void 0 ? void 0 : _powerLevels$users[botUserId]) !== null && _powerLevels$users$bo !== void 0 ? _powerLevels$users$bo : powerLevels.users_default) !== null && _ref !== void 0 ? _ref : 0;
+          if (!(currentBotPower < requiredPowerLevel)) {
+            _context.n = 8;
+            break;
+          }
+          updatedContent = _objectSpread(_objectSpread({}, powerLevels), {}, {
+            users: _objectSpread(_objectSpread({}, powerLevels.users), {}, (0, _defineProperty2["default"])({}, botUserId, requiredPowerLevel))
+          });
+          _context.n = 8;
+          return (0, _v1beta.setPowerLevels)(roomId, updatedContent, homeServerUrl, accessToken);
+        case 8:
+          return _context.a(2);
+      }
+    }, _callee, null, [[3, 5]]);
+  }));
+  return _invite.apply(this, arguments);
+}
+function invited(_x5, _x6) {
+  return _invited.apply(this, arguments);
+}
+function _invited() {
+  _invited = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(roomId, botUrl) {
+    var url, payload, response, data;
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
+        case 0:
+          if ((0, _validators.isValidRoomId)(roomId)) {
+            _context2.n = 1;
+            break;
+          }
+          throw new Error('Invalid room ID');
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/invited"));
+          payload = {
+            roomId: roomId
+          };
+          _context2.n = 2;
+          return (0, _nodeFetch["default"])(url, {
+            method: 'POST',
+            headers: {
+              'Content-Type': 'application/json'
+            },
+            body: JSON.stringify(payload)
+          });
+        case 2:
+          response = _context2.v;
+          if (response.ok) {
+            _context2.n = 3;
+            break;
+          }
+          _context2.n = 3;
+          return (0, _error.throwResponseError)(response);
+        case 3:
+          _context2.n = 4;
+          return response.json();
+        case 4:
+          data = _context2.v;
+          return _context2.a(2, data);
+      }
+    }, _callee2);
+  }));
+  return _invited.apply(this, arguments);
+}
+function getConfig(_x7) {
+  return _getConfig.apply(this, arguments);
+}
+function _getConfig() {
+  _getConfig = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee3(botUrl) {
+    var url, response, data;
+    return _regenerator().w(function (_context3) {
+      while (1) switch (_context3.n) {
+        case 0:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/config"));
+          _context3.n = 1;
+          return (0, _nodeFetch["default"])(url, {
+            method: 'GET',
+            headers: {
+              'Content-Type': 'application/json'
+            }
+          });
+        case 1:
+          response = _context3.v;
+          if (response.ok) {
+            _context3.n = 2;
+            break;
+          }
+          _context3.n = 2;
+          return (0, _error.throwResponseError)(response);
+        case 2:
+          _context3.n = 3;
+          return response.json();
+        case 3:
+          data = _context3.v;
+          return _context3.a(2, data);
+      }
+    }, _callee3);
+  }));
+  return _getConfig.apply(this, arguments);
+}

main/utils/headers.js

+"use strict";
+
+Object.defineProperty(exports, "__esModule", {
+  value: true
+});
+exports.botRestHeaders = botRestHeaders;
+function botRestHeaders(openIdToken, authDid) {
+  return {
+    'Content-Type': 'application/json',
+    'x-openid-token': openIdToken,
+    'x-did': authDid
+  };
+}

module/bot/v1beta1.js

+import _defineProperty from "@babel/runtime/helpers/esm/defineProperty";
+function ownKeys(e, r) { var t = Object.keys(e); if (Object.getOwnPropertySymbols) { var o = Object.getOwnPropertySymbols(e); r && (o = o.filter(function (r) { return Object.getOwnPropertyDescriptor(e, r).enumerable; })), t.push.apply(t, o); } return t; }
+function _objectSpread(e) { for (var r = 1; r < arguments.length; r++) { var t = null != arguments[r] ? arguments[r] : {}; r % 2 ? ownKeys(Object(t), !0).forEach(function (r) { _defineProperty(e, r, t[r]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(e, Object.getOwnPropertyDescriptors(t)) : ownKeys(Object(t)).forEach(function (r) { Object.defineProperty(e, r, Object.getOwnPropertyDescriptor(t, r)); }); } return e; }
+import fetch from 'node-fetch';
+import { throwResponseError } from '../utils/error';
+import { isValidRoomId } from '../utils/validators';
+import { cleanUrl } from '../utils/url';
+import { inviteUser, getPowerLevels, setPowerLevels } from '../api/room/v1beta1';
+export async function invite(roomId, botUrl, homeServerUrl, accessToken) {
+  var _powerLevels$state_de, _ref, _powerLevels$users$bo, _powerLevels$users;
+  if (!isValidRoomId(roomId)) {
+    throw new Error('Invalid room ID');
+  }
+  const config = await getConfig(botUrl);
+  const botUserId = config.data.bot.userId;
+  try {
+    await inviteUser(roomId, botUserId, homeServerUrl, accessToken);
+  } catch (error) {
+    var _error$body;
+    const message = (error === null || error === void 0 ? void 0 : error.message) || (error === null || error === void 0 ? void 0 : (_error$body = error.body) === null || _error$body === void 0 ? void 0 : _error$body.error) || '';
+    if (!message.includes('is already in the room')) {
+      throw error;
+    }
+  }
+  const powerLevels = await getPowerLevels(roomId, homeServerUrl, accessToken);
+  const requiredPowerLevel = (_powerLevels$state_de = powerLevels.state_default) !== null && _powerLevels$state_de !== void 0 ? _powerLevels$state_de : 50;
+  const currentBotPower = (_ref = (_powerLevels$users$bo = (_powerLevels$users = powerLevels.users) === null || _powerLevels$users === void 0 ? void 0 : _powerLevels$users[botUserId]) !== null && _powerLevels$users$bo !== void 0 ? _powerLevels$users$bo : powerLevels.users_default) !== null && _ref !== void 0 ? _ref : 0;
+  if (currentBotPower < requiredPowerLevel) {
+    const updatedContent = _objectSpread(_objectSpread({}, powerLevels), {}, {
+      users: _objectSpread(_objectSpread({}, powerLevels.users), {}, {
+        [botUserId]: requiredPowerLevel
+      })
+    });
+    await setPowerLevels(roomId, updatedContent, homeServerUrl, accessToken);
+  }
+}
+export async function invited(roomId, botUrl) {
+  if (!isValidRoomId(roomId)) {
+    throw new Error('Invalid room ID');
+  }
+  const url = cleanUrl(`${botUrl}/invited`);
+  const payload = {
+    roomId: roomId
+  };
+  const response = await fetch(url, {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json'
+    },
+    body: JSON.stringify(payload)
+  });
+  if (!response.ok) {
+    await throwResponseError(response);
+  }
+  const data = await response.json();
+  return data;
+}
+export async function getConfig(botUrl) {
+  const url = cleanUrl(`${botUrl}/config`);
+  const response = await fetch(url, {
+    method: 'GET',
+    headers: {
+      'Content-Type': 'application/json'
+    }
+  });
+  if (!response.ok) {
+    await throwResponseError(response);
+  }
+  const data = await response.json();
+  return data;
+}

module/utils/headers.js

+export function botRestHeaders(openIdToken, authDid) {
+  return {
+    'Content-Type': 'application/json',
+    'x-openid-token': openIdToken,
+    'x-did': authDid
+  };
+}

types/bot/v1beta1.d.ts

+export interface InvitedResponse {
+    isInvited: boolean;
+}
+export interface BotConfigResponse {
+    data: {
+        bot: {
+            userId: string;
+            localpart: string;
+            displayName: string;
+            homeServerName?: string;
+        };
+        homeserverUrl: string;
+        autojoin: boolean;
+        encryption: boolean;
+    };
+}
+export declare function invite(roomId: string, botUrl: string, homeServerUrl: string, accessToken: string): Promise<void>;
+export declare function invited(roomId: string, botUrl: string): Promise<InvitedResponse>;
+export declare function getConfig(botUrl: string): Promise<BotConfigResponse>;

types/utils/headers.d.ts

+export declare function botRestHeaders(openIdToken: string, authDid: string): {
+    'Content-Type': string;
+    'x-openid-token': string;
+    'x-did': string;
+};

main/api/account/v1beta1.js

@@ -7,7 +7,10 @@ "use strict";
 });
+exports.queryUsernameAvailable = queryUsernameAvailable;
 exports.queryWhoAmI = queryWhoAmI;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
 var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _error = require("../../utils/error");
+var _url = require("../../utils/url");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
 function queryWhoAmI(_x, _x2) {
@@ -17,38 +20,36 @@ return _queryWhoAmI.apply(this, arguments);
 function _queryWhoAmI() {
-  _queryWhoAmI = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(homeServerUrl, accessToken) {
+  _queryWhoAmI = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           if (accessToken) {
-            _context.next = 2;
+            _context.n = 1;
             break;
           }
           throw new Error('AccessToken cannot be empty');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/account/whoami");
-          _context.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/account/whoami"));
+          _context.n = 2;
           return (0, _nodeFetch["default"])(url, {
             method: 'GET',
             headers: {
+              'Content-Type': 'application/json',
               Authorization: "Bearer ".concat(accessToken)
             }
           });
-        case 5:
-          response = _context.sent;
+        case 2:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 9;
+            _context.n = 3;
             break;
           }
-          _context.next = 9;
+          _context.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context.next = 11;
+        case 3:
+          _context.n = 4;
           return response.json();
-        case 11:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 13:
-        case "end":
-          return _context.stop();
+        case 4:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -58,2 +59,62 @@ }, _callee);
   return _queryWhoAmI.apply(this, arguments);
+}
+function queryUsernameAvailable(_x3, _x4, _x5) {
+  return _queryUsernameAvailable.apply(this, arguments);
+}
+function _queryUsernameAvailable() {
+  _queryUsernameAvailable = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(username, homeServerUrl, accessToken) {
+    var url, response, _data, data, _t;
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.p = _context2.n) {
+        case 0:
+          if (username) {
+            _context2.n = 1;
+            break;
+          }
+          throw new Error('Username cannot be empty');
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/register/available?username=").concat(encodeURIComponent(username)));
+          _context2.n = 2;
+          return (0, _nodeFetch["default"])(url, {
+            method: 'GET',
+            headers: {
+              'Content-Type': 'application/json',
+              Authorization: "Bearer ".concat(accessToken)
+            }
+          });
+        case 2:
+          response = _context2.v;
+          if (response.ok) {
+            _context2.n = 8;
+            break;
+          }
+          _context2.p = 3;
+          _context2.n = 4;
+          return response.json();
+        case 4:
+          _data = _context2.v;
+          if (!((_data === null || _data === void 0 ? void 0 : _data.errcode) === 'M_USER_IN_USE')) {
+            _context2.n = 5;
+            break;
+          }
+          return _context2.a(2, false);
+        case 5:
+          _context2.n = 7;
+          break;
+        case 6:
+          _context2.p = 6;
+          _t = _context2.v;
+        case 7:
+          _context2.n = 8;
+          return (0, _error.throwResponseError)(response);
+        case 8:
+          _context2.n = 9;
+          return response.json();
+        case 9:
+          data = _context2.v;
+          return _context2.a(2, data === null || data === void 0 ? void 0 : data.available);
+      }
+    }, _callee2, null, [[3, 6]]);
+  }));
+  return _queryUsernameAvailable.apply(this, arguments);
 }

main/api/event/v1beta1.js

@@ -11,3 +11,2 @@ "use strict";
 exports.queryEvent = queryEvent;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
@@ -17,2 +16,5 @@ var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _validators = require("../../utils/validators");
+var _url = require("../../utils/url");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
 function queryEvent(_x, _x2, _x3, _x4) {
@@ -22,22 +24,22 @@ return _queryEvent.apply(this, arguments);
 function _queryEvent() {
-  _queryEvent = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(roomId, eventId, homeServerUrl, accessToken) {
+  _queryEvent = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(roomId, eventId, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           console.log('queryEvent', roomId, eventId, homeServerUrl, accessToken);
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context.next = 3;
+            _context.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 3:
+        case 1:
           if ((0, _validators.isValidEventId)(eventId)) {
-            _context.next = 5;
+            _context.n = 2;
             break;
           }
           throw new Error('Invalid event ID');
-        case 5:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/event/").concat(encodeURIComponent(eventId));
-          _context.next = 8;
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/event/").concat(encodeURIComponent(eventId)));
+          _context.n = 3;
           return (0, _nodeFetch["default"])(url, {
@@ -50,19 +52,16 @@ method: 'GET',
           });
-        case 8:
-          response = _context.sent;
+        case 3:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 12;
+            _context.n = 4;
             break;
           }
-          _context.next = 12;
+          _context.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 12:
-          _context.next = 14;
+        case 4:
+          _context.n = 5;
           return response.json();
-        case 14:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 16:
-        case "end":
-          return _context.stop();
+        case 5:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -77,21 +76,21 @@ }, _callee);
 function _queryChildEvents() {
-  _queryChildEvents = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(roomId, parentEventId, homeServerUrl, accessToken) {
+  _queryChildEvents = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(roomId, parentEventId, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context2.next = 2;
+            _context2.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidEventId)(parentEventId)) {
-            _context2.next = 4;
+            _context2.n = 2;
             break;
           }
           throw new Error('Invalid parent event ID');
-        case 4:
-          url = "".concat(homeServerUrl, "/_matrix/client/v1/rooms/").concat(encodeURIComponent(roomId), "/relations/").concat(encodeURIComponent(parentEventId));
-          _context2.next = 7;
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v1/rooms/").concat(encodeURIComponent(roomId), "/relations/").concat(encodeURIComponent(parentEventId)));
+          _context2.n = 3;
           return (0, _nodeFetch["default"])(url, {
@@ -104,19 +103,16 @@ method: 'GET',
           });
-        case 7:
-          response = _context2.sent;
+        case 3:
+          response = _context2.v;
           if (response.ok) {
-            _context2.next = 11;
+            _context2.n = 4;
             break;
           }
-          _context2.next = 11;
+          _context2.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 11:
-          _context2.next = 13;
+        case 4:
+          _context2.n = 5;
           return response.json();
-        case 13:
-          data = _context2.sent;
-          return _context2.abrupt("return", data);
-        case 15:
-        case "end":
-          return _context2.stop();
+        case 5:
+          data = _context2.v;
+          return _context2.a(2, data);
       }
@@ -131,21 +127,21 @@ }, _callee2);
 function _queryChildEventsByRelType() {
-  _queryChildEventsByRelType = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee3(roomId, parentEventId, relType, homeServerUrl, accessToken) {
+  _queryChildEventsByRelType = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee3(roomId, parentEventId, relType, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee3$(_context3) {
-      while (1) switch (_context3.prev = _context3.next) {
+    return _regenerator().w(function (_context3) {
+      while (1) switch (_context3.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context3.next = 2;
+            _context3.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidEventId)(parentEventId)) {
-            _context3.next = 4;
+            _context3.n = 2;
             break;
           }
           throw new Error('Invalid parent event ID');
-        case 4:
-          url = "".concat(homeServerUrl, "/_matrix/client/v1/rooms/").concat(encodeURIComponent(roomId), "/relations/").concat(encodeURIComponent(parentEventId), "/").concat(encodeURIComponent(relType));
-          _context3.next = 7;
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v1/rooms/").concat(encodeURIComponent(roomId), "/relations/").concat(encodeURIComponent(parentEventId), "/").concat(encodeURIComponent(relType)));
+          _context3.n = 3;
           return (0, _nodeFetch["default"])(url, {
@@ -158,19 +154,16 @@ method: 'GET',
           });
-        case 7:
-          response = _context3.sent;
+        case 3:
+          response = _context3.v;
           if (response.ok) {
-            _context3.next = 11;
+            _context3.n = 4;
             break;
           }
-          _context3.next = 11;
+          _context3.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 11:
-          _context3.next = 13;
+        case 4:
+          _context3.n = 5;
           return response.json();
-        case 13:
-          data = _context3.sent;
-          return _context3.abrupt("return", data);
-        case 15:
-        case "end":
-          return _context3.stop();
+        case 5:
+          data = _context3.v;
+          return _context3.a(2, data);
       }
@@ -185,27 +178,27 @@ }, _callee3);
 function _queryChildEventsByRelTypeAndEventType() {
-  _queryChildEventsByRelTypeAndEventType = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee4(roomId, parentEventId, relType, eventType, homeServerUrl, accessToken) {
+  _queryChildEventsByRelTypeAndEventType = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee4(roomId, parentEventId, relType, eventType, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee4$(_context4) {
-      while (1) switch (_context4.prev = _context4.next) {
+    return _regenerator().w(function (_context4) {
+      while (1) switch (_context4.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context4.next = 2;
+            _context4.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidEventId)(parentEventId)) {
-            _context4.next = 4;
+            _context4.n = 2;
             break;
           }
           throw new Error('Invalid parent event ID');
-        case 4:
+        case 2:
           if ((0, _validators.isValidEventType)(eventType)) {
-            _context4.next = 6;
+            _context4.n = 3;
             break;
           }
           throw new Error('Invalid event type');
-        case 6:
-          url = "".concat(homeServerUrl, "/_matrix/client/v1/rooms/").concat(encodeURIComponent(roomId), "/relations/").concat(encodeURIComponent(parentEventId), "/").concat(encodeURIComponent(relType), "/").concat(encodeURIComponent(eventType));
-          _context4.next = 9;
+        case 3:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v1/rooms/").concat(encodeURIComponent(roomId), "/relations/").concat(encodeURIComponent(parentEventId), "/").concat(encodeURIComponent(relType), "/").concat(encodeURIComponent(eventType)));
+          _context4.n = 4;
           return (0, _nodeFetch["default"])(url, {
@@ -218,19 +211,16 @@ method: 'GET',
           });
-        case 9:
-          response = _context4.sent;
+        case 4:
+          response = _context4.v;
           if (response.ok) {
-            _context4.next = 13;
+            _context4.n = 5;
             break;
           }
-          _context4.next = 13;
+          _context4.n = 5;
           return (0, _error.throwResponseError)(response);
-        case 13:
-          _context4.next = 15;
+        case 5:
+          _context4.n = 6;
           return response.json();
-        case 15:
-          data = _context4.sent;
-          return _context4.abrupt("return", data);
-        case 17:
-        case "end":
-          return _context4.stop();
+        case 6:
+          data = _context4.v;
+          return _context4.a(2, data);
       }
@@ -237,0 +227,0 @@ }, _callee4);

main/api/index.js

@@ -71,2 +71,5 @@ "use strict";
           return api.account.v1beta1.queryWhoAmI(overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken);
+        },
+        queryUsernameAvailable: function queryUsernameAvailable(username, overrideHomeServerUrl, overrideAccessToken) {
+          return api.account.v1beta1.queryUsernameAvailable(username, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken);
         }
@@ -103,2 +106,11 @@ }
           return api.room.v1beta1.kick(roomId, userId, reason, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken);
+        },
+        inviteUser: function inviteUser(roomId, userId, overrideHomeServerUrl, overrideAccessToken) {
+          return api.room.v1beta1.inviteUser(roomId, userId, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken);
+        },
+        getPowerLevels: function getPowerLevels(roomId, overrideHomeServerUrl, overrideAccessToken) {
+          return api.room.v1beta1.getPowerLevels(roomId, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken);
+        },
+        setPowerLevels: function setPowerLevels(roomId, content, overrideHomeServerUrl, overrideAccessToken) {
+          return api.room.v1beta1.setPowerLevels(roomId, content, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken);
         }
@@ -105,0 +117,0 @@ }

main/api/media/v1beta1.js

@@ -9,3 +9,2 @@ "use strict";
 exports.upload = upload;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
@@ -15,2 +14,4 @@ var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _url = require("../../utils/url");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
 var UploadContentType = exports.UploadContentType = /*#__PURE__*/function (UploadContentType) {
@@ -42,30 +43,29 @@ // PDF
 function _upload() {
-  _upload = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(filename, type, file, homeServerUrl, accessToken) {
+  _upload = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(filename, type, file, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           if (filename) {
-            _context.next = 2;
+            _context.n = 1;
             break;
           }
           throw new Error("'filename' is required to upload content");
-        case 2:
+        case 1:
           if (type) {
-            _context.next = 4;
+            _context.n = 2;
             break;
           }
           throw new Error("'type' is required to upload content");
-        case 4:
+        case 2:
           if (file) {
-            _context.next = 6;
+            _context.n = 3;
             break;
           }
           throw new Error("'file' is required to upload content");
-        case 6:
-          url = "".concat(homeServerUrl, "/_matrix/media/v3/upload");
-          url = (0, _url.cleanUrl)(url);
+        case 3:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/media/v3/upload"));
           url += "?filename=".concat(encodeURIComponent(filename));
-          _context.next = 11;
-          return (0, _nodeFetch["default"])((0, _url.cleanUrl)(url), {
+          _context.n = 4;
+          return (0, _nodeFetch["default"])(url, {
             method: 'POST',
@@ -78,16 +78,13 @@ headers: {
           });
-        case 11:
-          response = _context.sent;
+        case 4:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 15;
+            _context.n = 5;
             break;
           }
-          _context.next = 15;
+          _context.n = 5;
           return (0, _error.throwResponseError)(response);
-        case 15:
+        case 5:
           data = response.json();
-          return _context.abrupt("return", data);
-        case 17:
-        case "end":
-          return _context.stop();
+          return _context.a(2, data);
       }
@@ -94,0 +91,0 @@ }, _callee);

main/api/profile/v1beta1.js

@@ -12,3 +12,2 @@ "use strict";
 exports.setDisplayname = setDisplayname;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
@@ -18,2 +17,5 @@ var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _validators = require("../../utils/validators");
+var _url = require("../../utils/url");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
 function queryProfile(_x, _x2, _x3) {
@@ -23,15 +25,15 @@ return _queryProfile.apply(this, arguments);
 function _queryProfile() {
-  _queryProfile = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(userId, homeServerUrl, accessToken) {
+  _queryProfile = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(userId, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           if ((0, _validators.isValidUserId)(userId)) {
-            _context.next = 2;
+            _context.n = 1;
             break;
           }
           throw new Error('Invalid userId');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId));
-          _context.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId)));
+          _context.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -44,19 +46,16 @@ method: 'GET',
           });
-        case 5:
-          response = _context.sent;
+        case 2:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 9;
+            _context.n = 3;
             break;
           }
-          _context.next = 9;
+          _context.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context.next = 11;
+        case 3:
+          _context.n = 4;
           return response.json();
-        case 11:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 13:
-        case "end":
-          return _context.stop();
+        case 4:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -71,15 +70,15 @@ }, _callee);
 function _queryDisplayname() {
-  _queryDisplayname = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(userId, homeServerUrl, accessToken) {
+  _queryDisplayname = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(userId, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
         case 0:
           if ((0, _validators.isValidUserId)(userId)) {
-            _context2.next = 2;
+            _context2.n = 1;
             break;
           }
           throw new Error('Invalid userId');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId), "/displayname");
-          _context2.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId), "/displayname"));
+          _context2.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -92,19 +91,16 @@ method: 'GET',
           });
-        case 5:
-          response = _context2.sent;
+        case 2:
+          response = _context2.v;
           if (response.ok) {
-            _context2.next = 9;
+            _context2.n = 3;
             break;
           }
-          _context2.next = 9;
+          _context2.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context2.next = 11;
+        case 3:
+          _context2.n = 4;
           return response.json();
-        case 11:
-          data = _context2.sent;
-          return _context2.abrupt("return", data.displayname);
-        case 13:
-        case "end":
-          return _context2.stop();
+        case 4:
+          data = _context2.v;
+          return _context2.a(2, data.displayname);
       }
@@ -119,15 +115,15 @@ }, _callee2);
 function _queryAvatarUrl() {
-  _queryAvatarUrl = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee3(userId, homeServerUrl, accessToken) {
+  _queryAvatarUrl = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee3(userId, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee3$(_context3) {
-      while (1) switch (_context3.prev = _context3.next) {
+    return _regenerator().w(function (_context3) {
+      while (1) switch (_context3.n) {
         case 0:
           if ((0, _validators.isValidUserId)(userId)) {
-            _context3.next = 2;
+            _context3.n = 1;
             break;
           }
           throw new Error('Invalid userId');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId), "/avatar_url");
-          _context3.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId), "/avatar_url"));
+          _context3.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -140,19 +136,16 @@ method: 'GET',
           });
-        case 5:
-          response = _context3.sent;
+        case 2:
+          response = _context3.v;
           if (response.ok) {
-            _context3.next = 9;
+            _context3.n = 3;
             break;
           }
-          _context3.next = 9;
+          _context3.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context3.next = 11;
+        case 3:
+          _context3.n = 4;
           return response.json();
-        case 11:
-          data = _context3.sent;
-          return _context3.abrupt("return", data.avatar_url);
-        case 13:
-        case "end":
-          return _context3.stop();
+        case 4:
+          data = _context3.v;
+          return _context3.a(2, data.avatar_url);
       }
@@ -167,28 +160,28 @@ }, _callee3);
 function _setDisplayname() {
-  _setDisplayname = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee4(userId, displayname, homeServerUrl, accessToken) {
+  _setDisplayname = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee4(userId, displayname, homeServerUrl, accessToken) {
     var _data$displayname;
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee4$(_context4) {
-      while (1) switch (_context4.prev = _context4.next) {
+    return _regenerator().w(function (_context4) {
+      while (1) switch (_context4.n) {
         case 0:
           if ((0, _validators.isValidUserId)(userId)) {
-            _context4.next = 2;
+            _context4.n = 1;
             break;
           }
           throw new Error('Invalid userId');
-        case 2:
+        case 1:
           if (displayname) {
-            _context4.next = 4;
+            _context4.n = 2;
             break;
           }
           throw new Error('Displayname cannot be empty');
-        case 4:
+        case 2:
           if (!(typeof displayname !== 'string')) {
-            _context4.next = 6;
+            _context4.n = 3;
             break;
           }
           throw new Error('Displayname must be a string');
-        case 6:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId), "/displayname");
-          _context4.next = 9;
+        case 3:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId), "/displayname"));
+          _context4.n = 4;
           return (0, _nodeFetch["default"])(url, {
@@ -204,19 +197,16 @@ method: 'PUT',
           });
-        case 9:
-          response = _context4.sent;
+        case 4:
+          response = _context4.v;
           if (response.ok) {
-            _context4.next = 13;
+            _context4.n = 5;
             break;
           }
-          _context4.next = 13;
+          _context4.n = 5;
           return (0, _error.throwResponseError)(response);
-        case 13:
-          _context4.next = 15;
+        case 5:
+          _context4.n = 6;
           return response.json();
-        case 15:
-          data = _context4.sent;
-          return _context4.abrupt("return", (_data$displayname = data.displayname) !== null && _data$displayname !== void 0 ? _data$displayname : displayname);
-        case 17:
-        case "end":
-          return _context4.stop();
+        case 6:
+          data = _context4.v;
+          return _context4.a(2, (_data$displayname = data.displayname) !== null && _data$displayname !== void 0 ? _data$displayname : displayname);
       }
@@ -231,34 +221,34 @@ }, _callee4);
 function _setAvatarUrl() {
-  _setAvatarUrl = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee5(userId, avatarUrl, homeServerUrl, accessToken) {
+  _setAvatarUrl = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee5(userId, avatarUrl, homeServerUrl, accessToken) {
     var _data$avatar_url;
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee5$(_context5) {
-      while (1) switch (_context5.prev = _context5.next) {
+    return _regenerator().w(function (_context5) {
+      while (1) switch (_context5.n) {
         case 0:
           if ((0, _validators.isValidUserId)(userId)) {
-            _context5.next = 2;
+            _context5.n = 1;
             break;
           }
           throw new Error('Invalid userId');
-        case 2:
+        case 1:
           if (avatarUrl) {
-            _context5.next = 4;
+            _context5.n = 2;
             break;
           }
           throw new Error('Avatar URL cannot be empty');
-        case 4:
+        case 2:
           if (!(typeof avatarUrl !== 'string')) {
-            _context5.next = 6;
+            _context5.n = 3;
             break;
           }
           throw new Error('Avatar URL must be a string');
-        case 6:
+        case 3:
           if ((0, _validators.isValidMxcLink)(avatarUrl)) {
-            _context5.next = 8;
+            _context5.n = 4;
             break;
           }
           throw new Error('Invalid avatar URL');
-        case 8:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId), "/avatar_url");
-          _context5.next = 11;
+        case 4:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/profile/").concat(encodeURIComponent(userId), "/avatar_url"));
+          _context5.n = 5;
           return (0, _nodeFetch["default"])(url, {
@@ -274,19 +264,16 @@ method: 'PUT',
           });
-        case 11:
-          response = _context5.sent;
+        case 5:
+          response = _context5.v;
           if (response.ok) {
-            _context5.next = 15;
+            _context5.n = 6;
             break;
           }
-          _context5.next = 15;
+          _context5.n = 6;
           return (0, _error.throwResponseError)(response);
-        case 15:
-          _context5.next = 17;
+        case 6:
+          _context5.n = 7;
           return response.json();
-        case 17:
-          data = _context5.sent;
-          return _context5.abrupt("return", (_data$avatar_url = data.avatar_url) !== null && _data$avatar_url !== void 0 ? _data$avatar_url : avatarUrl);
-        case 19:
-        case "end":
-          return _context5.stop();
+        case 7:
+          data = _context5.v;
+          return _context5.a(2, (_data$avatar_url = data.avatar_url) !== null && _data$avatar_url !== void 0 ? _data$avatar_url : avatarUrl);
       }
@@ -293,0 +280,0 @@ }, _callee5);

main/api/room/v1beta1.js

@@ -7,2 +7,4 @@ "use strict";
 });
+exports.getPowerLevels = getPowerLevels;
+exports.inviteUser = inviteUser;
 exports.join = join;
@@ -16,4 +18,4 @@ exports.kick = kick;
 exports.queryVisibility = queryVisibility;
+exports.setPowerLevels = setPowerLevels;
 exports.setVisibility = setVisibility;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
@@ -23,2 +25,5 @@ var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _validators = require("../../utils/validators");
+var _url = require("../../utils/url");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
 function queryId(_x, _x2, _x3) {
@@ -28,15 +33,15 @@ return _queryId.apply(this, arguments);
 function _queryId() {
-  _queryId = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(alias, homeServerUrl, accessToken) {
+  _queryId = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(alias, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           if ((0, _validators.isValidRoomAlias)(alias)) {
-            _context.next = 2;
+            _context.n = 1;
             break;
           }
           throw new Error('Invalid room alias');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/directory/room/").concat(encodeURIComponent(alias));
-          _context.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/directory/room/").concat(encodeURIComponent(alias)));
+          _context.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -49,19 +54,16 @@ method: 'GET',
           });
-        case 5:
-          response = _context.sent;
+        case 2:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 9;
+            _context.n = 3;
             break;
           }
-          _context.next = 9;
+          _context.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context.next = 11;
+        case 3:
+          _context.n = 4;
           return response.json();
-        case 11:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 13:
-        case "end":
-          return _context.stop();
+        case 4:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -76,15 +78,15 @@ }, _callee);
 function _queryVisibility() {
-  _queryVisibility = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(roomId, homeServerUrl, accessToken) {
+  _queryVisibility = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(roomId, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context2.next = 2;
+            _context2.n = 1;
             break;
           }
           throw new Error('Invalid roomId');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/directory/list/room/").concat(encodeURIComponent(roomId));
-          _context2.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/directory/list/room/").concat(encodeURIComponent(roomId)));
+          _context2.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -97,19 +99,16 @@ method: 'GET',
           });
-        case 5:
-          response = _context2.sent;
+        case 2:
+          response = _context2.v;
           if (response.ok) {
-            _context2.next = 9;
+            _context2.n = 3;
             break;
           }
-          _context2.next = 9;
+          _context2.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context2.next = 11;
+        case 3:
+          _context2.n = 4;
           return response.json();
-        case 11:
-          data = _context2.sent;
-          return _context2.abrupt("return", data);
-        case 13:
-        case "end":
-          return _context2.stop();
+        case 4:
+          data = _context2.v;
+          return _context2.a(2, data);
       }
@@ -124,18 +123,18 @@ }, _callee2);
 function _setVisibility() {
-  _setVisibility = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee3(roomId, visibility, homeServerUrl, accessToken) {
+  _setVisibility = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee3(roomId, visibility, homeServerUrl, accessToken) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee3$(_context3) {
-      while (1) switch (_context3.prev = _context3.next) {
+    return _regenerator().w(function (_context3) {
+      while (1) switch (_context3.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context3.next = 2;
+            _context3.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/directory/list/room/").concat(encodeURIComponent(roomId));
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/directory/list/room/").concat(encodeURIComponent(roomId)));
           payload = {
             visibility: visibility
           };
-          _context3.next = 6;
+          _context3.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -149,19 +148,16 @@ method: 'PUT',
           });
-        case 6:
-          response = _context3.sent;
+        case 2:
+          response = _context3.v;
           if (response.ok) {
-            _context3.next = 10;
+            _context3.n = 3;
             break;
           }
-          _context3.next = 10;
+          _context3.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context3.next = 12;
+        case 3:
+          _context3.n = 4;
           return response.json();
-        case 12:
-          data = _context3.sent;
-          return _context3.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context3.stop();
+        case 4:
+          data = _context3.v;
+          return _context3.a(2, data);
       }
@@ -176,15 +172,15 @@ }, _callee3);
 function _knock() {
-  _knock = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee4(roomIdOrAlias, homeServerUrl, accessToken) {
+  _knock = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee4(roomIdOrAlias, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee4$(_context4) {
-      while (1) switch (_context4.prev = _context4.next) {
+    return _regenerator().w(function (_context4) {
+      while (1) switch (_context4.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomIdOrAlias)) {
-            _context4.next = 2;
+            _context4.n = 1;
             break;
           }
           throw new Error('Invalid room ID or alias');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/knock/").concat(encodeURIComponent(roomIdOrAlias));
-          _context4.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/knock/").concat(encodeURIComponent(roomIdOrAlias)));
+          _context4.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -197,19 +193,16 @@ method: 'POST',
           });
-        case 5:
-          response = _context4.sent;
+        case 2:
+          response = _context4.v;
           if (response.ok) {
-            _context4.next = 9;
+            _context4.n = 3;
             break;
           }
-          _context4.next = 9;
+          _context4.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context4.next = 11;
+        case 3:
+          _context4.n = 4;
           return response.json();
-        case 11:
-          data = _context4.sent;
-          return _context4.abrupt("return", data);
-        case 13:
-        case "end":
-          return _context4.stop();
+        case 4:
+          data = _context4.v;
+          return _context4.a(2, data);
       }
@@ -224,15 +217,15 @@ }, _callee4);
 function _join() {
-  _join = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee5(roomIdOrAlias, homeServerUrl, accessToken) {
+  _join = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee5(roomIdOrAlias, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee5$(_context5) {
-      while (1) switch (_context5.prev = _context5.next) {
+    return _regenerator().w(function (_context5) {
+      while (1) switch (_context5.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomIdOrAlias)) {
-            _context5.next = 2;
+            _context5.n = 1;
             break;
           }
           throw new Error('Invalid room ID or alias');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/join/").concat(encodeURIComponent(roomIdOrAlias));
-          _context5.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/join/").concat(encodeURIComponent(roomIdOrAlias)));
+          _context5.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -245,19 +238,16 @@ method: 'POST',
           });
-        case 5:
-          response = _context5.sent;
+        case 2:
+          response = _context5.v;
           if (response.ok) {
-            _context5.next = 9;
+            _context5.n = 3;
             break;
           }
-          _context5.next = 9;
+          _context5.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context5.next = 11;
+        case 3:
+          _context5.n = 4;
           return response.json();
-        case 11:
-          data = _context5.sent;
-          return _context5.abrupt("return", data);
-        case 13:
-        case "end":
-          return _context5.stop();
+        case 4:
+          data = _context5.v;
+          return _context5.a(2, data);
       }
@@ -272,9 +262,9 @@ }, _callee5);
 function _listJoinedRooms() {
-  _listJoinedRooms = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee6(homeServerUrl, accessToken) {
+  _listJoinedRooms = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee6(homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee6$(_context6) {
-      while (1) switch (_context6.prev = _context6.next) {
+    return _regenerator().w(function (_context6) {
+      while (1) switch (_context6.n) {
         case 0:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/joined_rooms");
-          _context6.next = 3;
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/joined_rooms"));
+          _context6.n = 1;
           return (0, _nodeFetch["default"])(url, {
@@ -287,19 +277,16 @@ method: 'GET',
           });
-        case 3:
-          response = _context6.sent;
+        case 1:
+          response = _context6.v;
           if (response.ok) {
-            _context6.next = 7;
+            _context6.n = 2;
             break;
           }
-          _context6.next = 7;
+          _context6.n = 2;
           return (0, _error.throwResponseError)(response);
-        case 7:
-          _context6.next = 9;
+        case 2:
+          _context6.n = 3;
           return response.json();
-        case 9:
-          data = _context6.sent;
-          return _context6.abrupt("return", data);
-        case 11:
-        case "end":
-          return _context6.stop();
+        case 3:
+          data = _context6.v;
+          return _context6.a(2, data);
       }
@@ -314,15 +301,15 @@ }, _callee6);
 function _listJoinedMembers() {
-  _listJoinedMembers = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee7(roomId, homeServerUrl, accessToken) {
+  _listJoinedMembers = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee7(roomId, homeServerUrl, accessToken) {
     var url, response, data;
-    return _regenerator["default"].wrap(function _callee7$(_context7) {
-      while (1) switch (_context7.prev = _context7.next) {
+    return _regenerator().w(function (_context7) {
+      while (1) switch (_context7.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context7.next = 2;
+            _context7.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/joined_members");
-          _context7.next = 5;
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/joined_members"));
+          _context7.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -335,19 +322,16 @@ method: 'GET',
           });
-        case 5:
-          response = _context7.sent;
+        case 2:
+          response = _context7.v;
           if (response.ok) {
-            _context7.next = 9;
+            _context7.n = 3;
             break;
           }
-          _context7.next = 9;
+          _context7.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 9:
-          _context7.next = 11;
+        case 3:
+          _context7.n = 4;
           return response.json();
-        case 11:
-          data = _context7.sent;
-          return _context7.abrupt("return", data);
-        case 13:
-        case "end":
-          return _context7.stop();
+        case 4:
+          data = _context7.v;
+          return _context7.a(2, data);
       }
@@ -362,18 +346,18 @@ }, _callee7);
 function _leave() {
-  _leave = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee8(roomId, reason, homeServerUrl, accessToken) {
+  _leave = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee8(roomId, reason, homeServerUrl, accessToken) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee8$(_context8) {
-      while (1) switch (_context8.prev = _context8.next) {
+    return _regenerator().w(function (_context8) {
+      while (1) switch (_context8.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context8.next = 2;
+            _context8.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/leave");
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/leave"));
           payload = {
             reason: reason
           };
-          _context8.next = 6;
+          _context8.n = 2;
           return (0, _nodeFetch["default"])(url, {
@@ -387,19 +371,16 @@ method: 'POST',
           });
-        case 6:
-          response = _context8.sent;
+        case 2:
+          response = _context8.v;
           if (response.ok) {
-            _context8.next = 10;
+            _context8.n = 3;
             break;
           }
-          _context8.next = 10;
+          _context8.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context8.next = 12;
+        case 3:
+          _context8.n = 4;
           return response.json();
-        case 12:
-          data = _context8.sent;
-          return _context8.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context8.stop();
+        case 4:
+          data = _context8.v;
+          return _context8.a(2, data);
       }
@@ -414,20 +395,20 @@ }, _callee8);
 function _kick() {
-  _kick = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee9(roomId, userId, reason, homeServerUrl, accessToken) {
+  _kick = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee9(roomId, userId, reason, homeServerUrl, accessToken) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee9$(_context9) {
-      while (1) switch (_context9.prev = _context9.next) {
+    return _regenerator().w(function (_context9) {
+      while (1) switch (_context9.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context9.next = 2;
+            _context9.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidUserId)(userId)) {
-            _context9.next = 4;
+            _context9.n = 2;
             break;
           }
           throw new Error('Invalid user ID');
-        case 4:
-          url = "".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/kick");
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/kick"));
           payload = {
@@ -437,3 +418,3 @@ user_id: userId,
           };
-          _context9.next = 8;
+          _context9.n = 3;
           return (0, _nodeFetch["default"])(url, {
@@ -447,19 +428,16 @@ method: 'POST',
           });
-        case 8:
-          response = _context9.sent;
+        case 3:
+          response = _context9.v;
           if (response.ok) {
-            _context9.next = 12;
+            _context9.n = 4;
             break;
           }
-          _context9.next = 12;
+          _context9.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 12:
-          _context9.next = 14;
+        case 4:
+          _context9.n = 5;
           return response.json();
-        case 14:
-          data = _context9.sent;
-          return _context9.abrupt("return", data);
-        case 16:
-        case "end":
-          return _context9.stop();
+        case 5:
+          data = _context9.v;
+          return _context9.a(2, data);
       }
@@ -469,2 +447,142 @@ }, _callee9);
   return _kick.apply(this, arguments);
+}
+function inviteUser(_x29, _x30, _x31, _x32) {
+  return _inviteUser.apply(this, arguments);
+}
+function _inviteUser() {
+  _inviteUser = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee0(roomId, userId, homeServerUrl, accessToken) {
+    var url, payload, response, data;
+    return _regenerator().w(function (_context0) {
+      while (1) switch (_context0.n) {
+        case 0:
+          if ((0, _validators.isValidRoomId)(roomId)) {
+            _context0.n = 1;
+            break;
+          }
+          throw new Error('Invalid room ID');
+        case 1:
+          if ((0, _validators.isValidUserId)(userId)) {
+            _context0.n = 2;
+            break;
+          }
+          throw new Error('Invalid user ID');
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/invite"));
+          payload = {
+            user_id: userId
+          };
+          _context0.n = 3;
+          return (0, _nodeFetch["default"])(url, {
+            method: 'POST',
+            headers: {
+              'Content-Type': 'application/json',
+              Authorization: "Bearer ".concat(accessToken)
+            },
+            body: JSON.stringify(payload)
+          });
+        case 3:
+          response = _context0.v;
+          if (response.ok) {
+            _context0.n = 4;
+            break;
+          }
+          _context0.n = 4;
+          return (0, _error.throwResponseError)(response);
+        case 4:
+          _context0.n = 5;
+          return response.json();
+        case 5:
+          data = _context0.v;
+          return _context0.a(2, data);
+      }
+    }, _callee0);
+  }));
+  return _inviteUser.apply(this, arguments);
+}
+function getPowerLevels(_x33, _x34, _x35) {
+  return _getPowerLevels.apply(this, arguments);
+}
+function _getPowerLevels() {
+  _getPowerLevels = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee1(roomId, homeServerUrl, accessToken) {
+    var url, response, data;
+    return _regenerator().w(function (_context1) {
+      while (1) switch (_context1.n) {
+        case 0:
+          if ((0, _validators.isValidRoomId)(roomId)) {
+            _context1.n = 1;
+            break;
+          }
+          throw new Error('Invalid room ID');
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/state/m.room.power_levels/"));
+          _context1.n = 2;
+          return (0, _nodeFetch["default"])(url, {
+            method: 'GET',
+            headers: {
+              'Content-Type': 'application/json',
+              Authorization: "Bearer ".concat(accessToken)
+            }
+          });
+        case 2:
+          response = _context1.v;
+          if (response.ok) {
+            _context1.n = 3;
+            break;
+          }
+          _context1.n = 3;
+          return (0, _error.throwResponseError)(response);
+        case 3:
+          _context1.n = 4;
+          return response.json();
+        case 4:
+          data = _context1.v;
+          return _context1.a(2, data);
+      }
+    }, _callee1);
+  }));
+  return _getPowerLevels.apply(this, arguments);
+}
+function setPowerLevels(_x36, _x37, _x38, _x39) {
+  return _setPowerLevels.apply(this, arguments);
+}
+function _setPowerLevels() {
+  _setPowerLevels = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee10(roomId, content, homeServerUrl, accessToken) {
+    var url, response, data;
+    return _regenerator().w(function (_context10) {
+      while (1) switch (_context10.n) {
+        case 0:
+          if ((0, _validators.isValidRoomId)(roomId)) {
+            _context10.n = 1;
+            break;
+          }
+          throw new Error('Invalid room ID');
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(homeServerUrl, "/_matrix/client/v3/rooms/").concat(encodeURIComponent(roomId), "/state/m.room.power_levels/"));
+          _context10.n = 2;
+          return (0, _nodeFetch["default"])(url, {
+            method: 'PUT',
+            headers: {
+              'Content-Type': 'application/json',
+              Authorization: "Bearer ".concat(accessToken)
+            },
+            body: JSON.stringify(content)
+          });
+        case 2:
+          response = _context10.v;
+          if (response.ok) {
+            _context10.n = 3;
+            break;
+          }
+          _context10.n = 3;
+          return (0, _error.throwResponseError)(response);
+        case 3:
+          _context10.n = 4;
+          return response.json();
+        case 4:
+          data = _context10.v;
+          return _context10.a(2, data);
+      }
+    }, _callee10);
+  }));
+  return _setPowerLevels.apply(this, arguments);
 }

main/bidBot/bid/v1beta1.js

@@ -15,3 +15,2 @@ "use strict";
 exports.submitBid = submitBid;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
@@ -22,20 +21,24 @@ var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
 var _validators = require("../../utils/validators");
+var _url = require("../../utils/url");
+var _headers = require("../../utils/headers");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
 function ownKeys(e, r) { var t = Object.keys(e); if (Object.getOwnPropertySymbols) { var o = Object.getOwnPropertySymbols(e); r && (o = o.filter(function (r) { return Object.getOwnPropertyDescriptor(e, r).enumerable; })), t.push.apply(t, o); } return t; }
 function _objectSpread(e) { for (var r = 1; r < arguments.length; r++) { var t = null != arguments[r] ? arguments[r] : {}; r % 2 ? ownKeys(Object(t), !0).forEach(function (r) { (0, _defineProperty2["default"])(e, r, t[r]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(e, Object.getOwnPropertyDescriptors(t)) : ownKeys(Object(t)).forEach(function (r) { Object.defineProperty(e, r, Object.getOwnPropertyDescriptor(t, r)); }); } return e; }
-function queryBids(_x, _x2, _x3, _x4) {
+function queryBids(_x, _x2, _x3, _x4, _x5) {
   return _queryBids.apply(this, arguments);
 }
 function _queryBids() {
-  _queryBids = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(collection, pagination, botUrl, accessToken) {
+  _queryBids = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(collection, pagination, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context.next = 2;
+            _context.n = 1;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 2:
-          url = "".concat(botUrl, "/action");
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -49,28 +52,22 @@ action: 'get-bids',
           };
-          _context.next = 6;
+          _context.n = 2;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 6:
-          response = _context.sent;
+        case 2:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 10;
+            _context.n = 3;
             break;
           }
-          _context.next = 10;
+          _context.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context.next = 12;
+        case 3:
+          _context.n = 4;
           return response.json();
-        case 12:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context.stop();
+        case 4:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -81,24 +78,24 @@ }, _callee);
 }
-function queryBidsByDid(_x5, _x6, _x7, _x8) {
+function queryBidsByDid(_x6, _x7, _x8, _x9, _x0) {
   return _queryBidsByDid.apply(this, arguments);
 }
 function _queryBidsByDid() {
-  _queryBidsByDid = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(collection, did, botUrl, accessToken) {
+  _queryBidsByDid = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(collection, did, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
         case 0:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context2.next = 2;
+            _context2.n = 1;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidDid)(did)) {
-            _context2.next = 4;
+            _context2.n = 2;
             break;
           }
           throw new Error('Invalid DID');
-        case 4:
-          url = "".concat(botUrl, "/action");
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -111,28 +108,22 @@ action: 'get-bids-by-did',
           };
-          _context2.next = 8;
+          _context2.n = 3;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 8:
-          response = _context2.sent;
+        case 3:
+          response = _context2.v;
           if (response.ok) {
-            _context2.next = 12;
+            _context2.n = 4;
             break;
           }
-          _context2.next = 12;
+          _context2.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 12:
-          _context2.next = 14;
+        case 4:
+          _context2.n = 5;
           return response.json();
-        case 14:
-          data = _context2.sent;
-          return _context2.abrupt("return", data);
-        case 16:
-        case "end":
-          return _context2.stop();
+        case 5:
+          data = _context2.v;
+          return _context2.a(2, data);
       }
@@ -143,24 +134,24 @@ }, _callee2);
 }
-function submitBid(_x9, _x0, _x1, _x10, _x11) {
+function submitBid(_x1, _x10, _x11, _x12, _x13, _x14) {
   return _submitBid.apply(this, arguments);
 }
 function _submitBid() {
-  _submitBid = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee3(collection, bid, role, botUrl, accessToken) {
+  _submitBid = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee3(collection, bid, role, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee3$(_context3) {
-      while (1) switch (_context3.prev = _context3.next) {
+    return _regenerator().w(function (_context3) {
+      while (1) switch (_context3.n) {
         case 0:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context3.next = 2;
+            _context3.n = 1;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidBidRole)(role)) {
-            _context3.next = 4;
+            _context3.n = 2;
             break;
           }
           throw new Error('Invalid role');
-        case 4:
-          url = "".concat(botUrl, "/action");
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -174,28 +165,22 @@ action: 'submit-bid',
           };
-          _context3.next = 8;
+          _context3.n = 3;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 8:
-          response = _context3.sent;
+        case 3:
+          response = _context3.v;
           if (response.ok) {
-            _context3.next = 12;
+            _context3.n = 4;
             break;
           }
-          _context3.next = 12;
+          _context3.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 12:
-          _context3.next = 14;
+        case 4:
+          _context3.n = 5;
           return response.json();
-        case 14:
-          data = _context3.sent;
-          return _context3.abrupt("return", data === null || data === void 0 ? void 0 : data.data);
-        case 16:
-        case "end":
-          return _context3.stop();
+        case 5:
+          data = _context3.v;
+          return _context3.a(2, data === null || data === void 0 ? void 0 : data.data);
       }
@@ -206,30 +191,30 @@ }, _callee3);
 }
-function approveBid(_x12, _x13, _x14, _x15, _x16) {
+function approveBid(_x15, _x16, _x17, _x18, _x19, _x20) {
   return _approveBid.apply(this, arguments);
 }
 function _approveBid() {
-  _approveBid = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee4(bidId, collection, did, botUrl, accessToken) {
+  _approveBid = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee4(bidId, collection, did, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee4$(_context4) {
-      while (1) switch (_context4.prev = _context4.next) {
+    return _regenerator().w(function (_context4) {
+      while (1) switch (_context4.n) {
         case 0:
           if ((0, _validators.isValidEventId)(bidId)) {
-            _context4.next = 2;
+            _context4.n = 1;
             break;
           }
           throw new Error('Invalid bid ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context4.next = 4;
+            _context4.n = 2;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 4:
+        case 2:
           if ((0, _validators.isValidDid)(did)) {
-            _context4.next = 6;
+            _context4.n = 3;
             break;
           }
           throw new Error('Invalid DID');
-        case 6:
-          url = "".concat(botUrl, "/action");
+        case 3:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -244,28 +229,22 @@ action: 'evaluate-bid',
           };
-          _context4.next = 10;
+          _context4.n = 4;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 10:
-          response = _context4.sent;
+        case 4:
+          response = _context4.v;
           if (response.ok) {
-            _context4.next = 14;
+            _context4.n = 5;
             break;
           }
-          _context4.next = 14;
+          _context4.n = 5;
           return (0, _error.throwResponseError)(response);
-        case 14:
-          _context4.next = 16;
+        case 5:
+          _context4.n = 6;
           return response.json();
-        case 16:
-          data = _context4.sent;
-          return _context4.abrupt("return", data === null || data === void 0 ? void 0 : data.data);
-        case 18:
-        case "end":
-          return _context4.stop();
+        case 6:
+          data = _context4.v;
+          return _context4.a(2, data === null || data === void 0 ? void 0 : data.data);
       }
@@ -276,30 +255,30 @@ }, _callee4);
 }
-function rejectBid(_x17, _x18, _x19, _x20, _x21, _x22) {
+function rejectBid(_x21, _x22, _x23, _x24, _x25, _x26, _x27) {
   return _rejectBid.apply(this, arguments);
 }
 function _rejectBid() {
-  _rejectBid = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee5(bidId, collection, did, reason, botUrl, accessToken) {
+  _rejectBid = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee5(bidId, collection, did, reason, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee5$(_context5) {
-      while (1) switch (_context5.prev = _context5.next) {
+    return _regenerator().w(function (_context5) {
+      while (1) switch (_context5.n) {
         case 0:
           if ((0, _validators.isValidEventId)(bidId)) {
-            _context5.next = 2;
+            _context5.n = 1;
             break;
           }
           throw new Error('Invalid bid ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context5.next = 4;
+            _context5.n = 2;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 4:
+        case 2:
           if ((0, _validators.isValidDid)(did)) {
-            _context5.next = 6;
+            _context5.n = 3;
             break;
           }
           throw new Error('Invalid DID');
-        case 6:
-          url = "".concat(botUrl, "/action");
+        case 3:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -317,28 +296,22 @@ action: 'evaluate-bid',
           };
-          _context5.next = 10;
+          _context5.n = 4;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 10:
-          response = _context5.sent;
+        case 4:
+          response = _context5.v;
           if (response.ok) {
-            _context5.next = 14;
+            _context5.n = 5;
             break;
           }
-          _context5.next = 14;
+          _context5.n = 5;
           return (0, _error.throwResponseError)(response);
-        case 14:
-          _context5.next = 16;
+        case 5:
+          _context5.n = 6;
           return response.json();
-        case 16:
-          data = _context5.sent;
-          return _context5.abrupt("return", data === null || data === void 0 ? void 0 : data.data);
-        case 18:
-        case "end":
-          return _context5.stop();
+        case 6:
+          data = _context5.v;
+          return _context5.a(2, data === null || data === void 0 ? void 0 : data.data);
       }
@@ -349,24 +322,24 @@ }, _callee5);
 }
-function queryDidIsBlocked(_x23, _x24, _x25, _x26) {
+function queryDidIsBlocked(_x28, _x29, _x30, _x31, _x32) {
   return _queryDidIsBlocked.apply(this, arguments);
 }
 function _queryDidIsBlocked() {
-  _queryDidIsBlocked = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee6(collection, did, botUrl, accessToken) {
+  _queryDidIsBlocked = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee6(collection, did, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee6$(_context6) {
-      while (1) switch (_context6.prev = _context6.next) {
+    return _regenerator().w(function (_context6) {
+      while (1) switch (_context6.n) {
         case 0:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context6.next = 2;
+            _context6.n = 1;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidDid)(did)) {
-            _context6.next = 4;
+            _context6.n = 2;
             break;
           }
           throw new Error('Invalid DID');
-        case 4:
-          url = "".concat(botUrl, "/action");
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -379,28 +352,22 @@ action: 'did-is-blocked',
           };
-          _context6.next = 8;
+          _context6.n = 3;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 8:
-          response = _context6.sent;
+        case 3:
+          response = _context6.v;
           if (response.ok) {
-            _context6.next = 12;
+            _context6.n = 4;
             break;
           }
-          _context6.next = 12;
+          _context6.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 12:
-          _context6.next = 14;
+        case 4:
+          _context6.n = 5;
           return response.json();
-        case 14:
-          data = _context6.sent;
-          return _context6.abrupt("return", data === null || data === void 0 ? void 0 : data.data);
-        case 16:
-        case "end":
-          return _context6.stop();
+        case 5:
+          data = _context6.v;
+          return _context6.a(2, data === null || data === void 0 ? void 0 : data.data);
       }
@@ -411,24 +378,24 @@ }, _callee6);
 }
-function didBlock(_x27, _x28, _x29, _x30) {
+function didBlock(_x33, _x34, _x35, _x36, _x37) {
   return _didBlock.apply(this, arguments);
 }
 function _didBlock() {
-  _didBlock = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee7(collection, did, botUrl, accessToken) {
+  _didBlock = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee7(collection, did, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee7$(_context7) {
-      while (1) switch (_context7.prev = _context7.next) {
+    return _regenerator().w(function (_context7) {
+      while (1) switch (_context7.n) {
         case 0:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context7.next = 2;
+            _context7.n = 1;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidDid)(did)) {
-            _context7.next = 4;
+            _context7.n = 2;
             break;
           }
           throw new Error('Invalid DID');
-        case 4:
-          url = "".concat(botUrl, "/action");
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -441,28 +408,22 @@ action: 'did-block',
           };
-          _context7.next = 8;
+          _context7.n = 3;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 8:
-          response = _context7.sent;
+        case 3:
+          response = _context7.v;
           if (response.ok) {
-            _context7.next = 12;
+            _context7.n = 4;
             break;
           }
-          _context7.next = 12;
+          _context7.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 12:
-          _context7.next = 14;
+        case 4:
+          _context7.n = 5;
           return response.json();
-        case 14:
-          data = _context7.sent;
-          return _context7.abrupt("return", data === null || data === void 0 ? void 0 : data.data);
-        case 16:
-        case "end":
-          return _context7.stop();
+        case 5:
+          data = _context7.v;
+          return _context7.a(2, data === null || data === void 0 ? void 0 : data.data);
       }
@@ -473,24 +434,24 @@ }, _callee7);
 }
-function didUnblock(_x31, _x32, _x33, _x34) {
+function didUnblock(_x38, _x39, _x40, _x41, _x42) {
   return _didUnblock.apply(this, arguments);
 }
 function _didUnblock() {
-  _didUnblock = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee8(collection, did, botUrl, accessToken) {
+  _didUnblock = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee8(collection, did, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee8$(_context8) {
-      while (1) switch (_context8.prev = _context8.next) {
+    return _regenerator().w(function (_context8) {
+      while (1) switch (_context8.n) {
         case 0:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context8.next = 2;
+            _context8.n = 1;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 2:
+        case 1:
           if ((0, _validators.isValidDid)(did)) {
-            _context8.next = 4;
+            _context8.n = 2;
             break;
           }
           throw new Error('Invalid DID');
-        case 4:
-          url = "".concat(botUrl, "/action");
+        case 2:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -503,28 +464,22 @@ action: 'did-unblock',
           };
-          _context8.next = 8;
+          _context8.n = 3;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 8:
-          response = _context8.sent;
+        case 3:
+          response = _context8.v;
           if (response.ok) {
-            _context8.next = 12;
+            _context8.n = 4;
             break;
           }
-          _context8.next = 12;
+          _context8.n = 4;
           return (0, _error.throwResponseError)(response);
-        case 12:
-          _context8.next = 14;
+        case 4:
+          _context8.n = 5;
           return response.json();
-        case 14:
-          data = _context8.sent;
-          return _context8.abrupt("return", data === null || data === void 0 ? void 0 : data.data);
-        case 16:
-        case "end":
-          return _context8.stop();
+        case 5:
+          data = _context8.v;
+          return _context8.a(2, data === null || data === void 0 ? void 0 : data.data);
       }
@@ -531,0 +486,0 @@ }, _callee8);

main/bidBot/index.js

 "use strict";
 
-var _typeof = require("@babel/runtime/helpers/typeof");
 Object.defineProperty(exports, "__esModule", {
@@ -8,45 +7,34 @@ value: true
 exports.createMatrixBidBotClient = createMatrixBidBotClient;
-var _1 = _interopRequireWildcard(require("./bid/v1beta1"));
-var _2 = _interopRequireWildcard(require("./bot/v1beta1"));
-function _interopRequireWildcard(e, t) { if ("function" == typeof WeakMap) var r = new WeakMap(), n = new WeakMap(); return (_interopRequireWildcard = function _interopRequireWildcard(e, t) { if (!t && e && e.__esModule) return e; var o, i, f = { __proto__: null, "default": e }; if (null === e || "object" != _typeof(e) && "function" != typeof e) return f; if (o = t ? n : r) { if (o.has(e)) return o.get(e); o.set(e, f); } for (var _t in e) "default" !== _t && {}.hasOwnProperty.call(e, _t) && ((i = (o = Object.defineProperty) && Object.getOwnPropertyDescriptor(e, _t)) && (i.get || i.set) ? o(f, _t, i) : f[_t] = e[_t]); return f; })(e, t); }
-var bidBot;
-(function (_bidBot) {
-  var bid;
-  (function (_bid) {
-    var v1beta1 = _bid.v1beta1 = _1;
-  })(bid || (bid = _bidBot.bid || (_bidBot.bid = {})));
-  var bot;
-  (function (_bot) {
-    var v1beta1 = _bot.v1beta1 = _2;
-  })(bot || (bot = _bidBot.bot || (_bidBot.bot = {})));
-})(bidBot || (bidBot = {}));
+var _v1beta = require("./bid/v1beta1");
+var _v1beta2 = require("../bot/v1beta1");
 function createMatrixBidBotClient(_ref) {
   var botUrl = _ref.botUrl,
-    accessToken = _ref.accessToken;
+    accessToken = _ref.accessToken,
+    homeServerUrl = _ref.homeServerUrl;
   return {
     bid: {
       v1beta1: {
-        queryBids: function queryBids(collection, pagination, overrideBotUrl, overrideAccessToken) {
-          return bidBot.bid.v1beta1.queryBids(collection, pagination, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        queryBids: function queryBids(collection, openIdToken, authDid, pagination, overrideBotUrl) {
+          return (0, _v1beta.queryBids)(collection, pagination, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        queryBidsByDid: function queryBidsByDid(collection, did, overrideBotUrl, overrideAccessToken) {
-          return bidBot.bid.v1beta1.queryBidsByDid(collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        queryBidsByDid: function queryBidsByDid(collection, did, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.queryBidsByDid)(collection, did, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        submitBid: function submitBid(collection, did, role, overrideBotUrl, overrideAccessToken) {
-          return bidBot.bid.v1beta1.submitBid(collection, did, role, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        submitBid: function submitBid(collection, bid, role, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.submitBid)(collection, bid, role, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        approveBid: function approveBid(bidId, collection, did, overrideBotUrl, overrideAccessToken) {
-          return bidBot.bid.v1beta1.approveBid(bidId, collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        approveBid: function approveBid(bidId, collection, did, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.approveBid)(bidId, collection, did, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        rejectBid: function rejectBid(bidId, collection, did, reason, overrideBotUrl, overrideAccessToken) {
-          return bidBot.bid.v1beta1.rejectBid(bidId, collection, did, reason, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        rejectBid: function rejectBid(bidId, collection, did, reason, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.rejectBid)(bidId, collection, did, reason, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        queryDidIsBlocked: function queryDidIsBlocked(collection, did, overrideBotUrl, overrideAccessToken) {
-          return bidBot.bid.v1beta1.queryDidIsBlocked(collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        queryDidIsBlocked: function queryDidIsBlocked(collection, did, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.queryDidIsBlocked)(collection, did, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        didBlock: function didBlock(collection, did, overrideBotUrl, overrideAccessToken) {
-          return bidBot.bid.v1beta1.didBlock(collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        didBlock: function didBlock(collection, did, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.didBlock)(collection, did, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        didUnblock: function didUnblock(collection, did, overrideBotUrl, overrideAccessToken) {
-          return bidBot.bid.v1beta1.didUnblock(collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        didUnblock: function didUnblock(collection, did, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.didUnblock)(collection, did, overrideBotUrl || botUrl, openIdToken, authDid);
         }
@@ -58,6 +46,9 @@ }
         invite: function invite(roomId) {
-          return bidBot.bot.v1beta1.invite(roomId, botUrl, accessToken);
+          return (0, _v1beta2.invite)(roomId, botUrl, homeServerUrl, accessToken);
         },
         invited: function invited(roomId) {
-          return bidBot.bot.v1beta1.invited(roomId, botUrl);
+          return (0, _v1beta2.invited)(roomId, botUrl);
+        },
+        getConfig: function getConfig() {
+          return (0, _v1beta2.getConfig)(botUrl);
         }
@@ -64,0 +55,0 @@ }

main/claimBot/claim/v1beta1.js

@@ -9,3 +9,2 @@ "use strict";
 exports.saveClaim = saveClaim;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
@@ -15,18 +14,22 @@ var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _validators = require("../../utils/validators");
-function queryClaim(_x, _x2, _x3, _x4) {
+var _url = require("../../utils/url");
+var _headers = require("../../utils/headers");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
+function queryClaim(_x, _x2, _x3, _x4, _x5) {
   return _queryClaim.apply(this, arguments);
 }
 function _queryClaim() {
-  _queryClaim = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(collection, cid, botUrl, accessToken) {
+  _queryClaim = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(collection, cid, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context.next = 2;
+            _context.n = 1;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 2:
-          url = "".concat(botUrl, "/action");
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -39,28 +42,22 @@ action: 'get-claim',
           };
-          _context.next = 6;
+          _context.n = 2;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 6:
-          response = _context.sent;
+        case 2:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 10;
+            _context.n = 3;
             break;
           }
-          _context.next = 10;
+          _context.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context.next = 12;
+        case 3:
+          _context.n = 4;
           return response.json();
-        case 12:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context.stop();
+        case 4:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -71,18 +68,18 @@ }, _callee);
 }
-function saveClaim(_x5, _x6, _x7, _x8) {
+function saveClaim(_x6, _x7, _x8, _x9, _x0) {
   return _saveClaim.apply(this, arguments);
 }
 function _saveClaim() {
-  _saveClaim = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(collection, claim, botUrl, accessToken) {
+  _saveClaim = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(collection, claim, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
         case 0:
           if ((0, _validators.isValidCollectionId)(collection)) {
-            _context2.next = 2;
+            _context2.n = 1;
             break;
           }
           throw new Error('Invalid collection ID');
-        case 2:
-          url = "".concat(botUrl, "/action");
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -95,28 +92,22 @@ action: 'save-claim',
           };
-          _context2.next = 6;
+          _context2.n = 2;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 6:
-          response = _context2.sent;
+        case 2:
+          response = _context2.v;
           if (response.ok) {
-            _context2.next = 10;
+            _context2.n = 3;
             break;
           }
-          _context2.next = 10;
+          _context2.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context2.next = 12;
+        case 3:
+          _context2.n = 4;
           return response.json();
-        case 12:
-          data = _context2.sent;
-          return _context2.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context2.stop();
+        case 4:
+          data = _context2.v;
+          return _context2.a(2, data);
       }
@@ -123,0 +114,0 @@ }, _callee2);

main/claimBot/index.js

 "use strict";
 
-var _typeof = require("@babel/runtime/helpers/typeof");
 Object.defineProperty(exports, "__esModule", {
@@ -8,27 +7,16 @@ value: true
 exports.createMatrixClaimBotClient = createMatrixClaimBotClient;
-var _1 = _interopRequireWildcard(require("./claim/v1beta1"));
-var _2 = _interopRequireWildcard(require("./bot/v1beta1"));
-function _interopRequireWildcard(e, t) { if ("function" == typeof WeakMap) var r = new WeakMap(), n = new WeakMap(); return (_interopRequireWildcard = function _interopRequireWildcard(e, t) { if (!t && e && e.__esModule) return e; var o, i, f = { __proto__: null, "default": e }; if (null === e || "object" != _typeof(e) && "function" != typeof e) return f; if (o = t ? n : r) { if (o.has(e)) return o.get(e); o.set(e, f); } for (var _t in e) "default" !== _t && {}.hasOwnProperty.call(e, _t) && ((i = (o = Object.defineProperty) && Object.getOwnPropertyDescriptor(e, _t)) && (i.get || i.set) ? o(f, _t, i) : f[_t] = e[_t]); return f; })(e, t); }
-var claimBot;
-(function (_claimBot) {
-  var claim;
-  (function (_claim) {
-    var v1beta1 = _claim.v1beta1 = _1;
-  })(claim || (claim = _claimBot.claim || (_claimBot.claim = {})));
-  var bot;
-  (function (_bot) {
-    var v1beta1 = _bot.v1beta1 = _2;
-  })(bot || (bot = _claimBot.bot || (_claimBot.bot = {})));
-})(claimBot || (claimBot = {}));
+var _v1beta = require("./claim/v1beta1");
+var _v1beta2 = require("../bot/v1beta1");
 function createMatrixClaimBotClient(_ref) {
   var botUrl = _ref.botUrl,
-    accessToken = _ref.accessToken;
+    accessToken = _ref.accessToken,
+    homeServerUrl = _ref.homeServerUrl;
   return {
     claim: {
       v1beta1: {
-        queryClaim: function queryClaim(collection, cid) {
-          return claimBot.claim.v1beta1.queryClaim(collection, cid, botUrl, accessToken);
+        queryClaim: function queryClaim(collection, cid, openIdToken, authDid) {
+          return (0, _v1beta.queryClaim)(collection, cid, botUrl, openIdToken, authDid);
         },
-        saveClaim: function saveClaim(collection, claim) {
-          return claimBot.claim.v1beta1.saveClaim(collection, claim, botUrl, accessToken);
+        saveClaim: function saveClaim(collection, claim, openIdToken, authDid) {
+          return (0, _v1beta.saveClaim)(collection, claim, botUrl, openIdToken, authDid);
         }
@@ -40,6 +28,9 @@ }
         invite: function invite(roomId) {
-          return claimBot.bot.v1beta1.invite(roomId, botUrl, accessToken);
+          return (0, _v1beta2.invite)(roomId, botUrl, homeServerUrl, accessToken);
         },
         invited: function invited(roomId) {
-          return claimBot.bot.v1beta1.invited(roomId, botUrl);
+          return (0, _v1beta2.invited)(roomId, botUrl);
+        },
+        getConfig: function getConfig() {
+          return (0, _v1beta2.getConfig)(botUrl);
         }
@@ -46,0 +37,0 @@ }

main/roomBot/index.js

@@ -24,13 +24,13 @@ "use strict";
       v1beta1: {
-        sourceRoom: function sourceRoom(did, overrideBotUrl, overrideAccessToken, groupUsers) {
-          return roomBot.room.v1beta1.sourceRoom(did, overrideBotUrl || botUrl, overrideAccessToken || accessToken, groupUsers);
+        sourceRoom: function sourceRoom(did, openIdToken, authDid, overrideBotUrl, groupUsers) {
+          return roomBot.room.v1beta1.sourceRoom(did, overrideBotUrl || botUrl, openIdToken, authDid, groupUsers);
         },
-        sourceRoomAndJoin: function sourceRoomAndJoin(did, overrideHomeServerUrl, overrideBotUrl, overrideAccessToken, groupUsers) {
-          return roomBot.room.v1beta1.sourceRoomAndJoin(did, overrideHomeServerUrl || homeServerUrl, overrideBotUrl || botUrl, overrideAccessToken || accessToken, groupUsers);
+        sourceRoomAndJoin: function sourceRoomAndJoin(did, openIdToken, authDid, overrideHomeServerUrl, overrideBotUrl, overrideAccessToken, groupUsers) {
+          return roomBot.room.v1beta1.sourceRoomAndJoin(did, overrideHomeServerUrl || homeServerUrl, overrideBotUrl || botUrl, openIdToken, authDid, overrideAccessToken || accessToken, groupUsers);
         },
-        roomInvite: function roomInvite(did, overrideBotUrl, overrideAccessToken, groupUsers) {
-          return roomBot.room.v1beta1.roomInvite(did, overrideBotUrl || botUrl, overrideAccessToken || accessToken, groupUsers);
+        roomInvite: function roomInvite(did, openIdToken, authDid, overrideBotUrl, groupUsers) {
+          return roomBot.room.v1beta1.roomInvite(did, overrideBotUrl || botUrl, openIdToken, authDid, groupUsers);
         },
-        roomInviteAndJoin: function roomInviteAndJoin(did, overrideHomeServerUrl, overrideBotUrl, overrideAccessToken, groupUsers) {
-          return roomBot.room.v1beta1.roomInviteAndJoin(did, overrideHomeServerUrl || homeServerUrl, overrideBotUrl || botUrl, overrideAccessToken || accessToken, groupUsers);
+        roomInviteAndJoin: function roomInviteAndJoin(did, openIdToken, authDid, overrideHomeServerUrl, overrideBotUrl, overrideAccessToken, groupUsers) {
+          return roomBot.room.v1beta1.roomInviteAndJoin(did, overrideHomeServerUrl || homeServerUrl, overrideBotUrl || botUrl, openIdToken, authDid, overrideAccessToken || accessToken, groupUsers);
         }
@@ -37,0 +37,0 @@ }

main/roomBot/room/v1beta1.js

@@ -11,3 +11,2 @@ "use strict";
 exports.sourceRoomAndJoin = sourceRoomAndJoin;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
@@ -17,13 +16,17 @@ var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _v1beta = require("../../api/room/v1beta1");
-// WIll only create room if not exists yet
-function sourceRoom(_x, _x2, _x3, _x4) {
+var _url = require("../../utils/url");
+var _headers = require("../../utils/headers");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
+// Will only create room if not exists yet
+function sourceRoom(_x, _x2, _x3, _x4, _x5) {
   return _sourceRoom.apply(this, arguments);
 }
 function _sourceRoom() {
-  _sourceRoom = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(did, botUrl, accessToken, groupUsers) {
+  _sourceRoom = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(did, botUrl, openIdToken, authDid, groupUsers) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
-          url = "".concat(botUrl, "/room/source");
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/room/source"));
           payload = {
@@ -33,28 +36,22 @@ did: did,
           };
-          _context.next = 4;
+          _context.n = 1;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: accessToken ? "Bearer ".concat(accessToken) : undefined
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 4:
-          response = _context.sent;
+        case 1:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 8;
+            _context.n = 2;
             break;
           }
-          _context.next = 8;
+          _context.n = 2;
           return (0, _error.throwResponseError)(response);
-        case 8:
-          _context.next = 10;
+        case 2:
+          _context.n = 3;
           return response.json();
-        case 10:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 12:
-        case "end":
-          return _context.stop();
+        case 3:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -65,43 +62,39 @@ }, _callee);
 }
-function sourceRoomAndJoin(_x5, _x6, _x7, _x8, _x9) {
+function sourceRoomAndJoin(_x6, _x7, _x8, _x9, _x0, _x1, _x10) {
   return _sourceRoomAndJoin.apply(this, arguments);
 }
 function _sourceRoomAndJoin() {
-  _sourceRoomAndJoin = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(did, homeServerUrl, botUrl, accessToken, groupUsers) {
+  _sourceRoomAndJoin = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(did, homeServerUrl, botUrl, openIdToken, authDid, accessToken, groupUsers) {
     var createRoomResponse, roomId, joinRoomResponse;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
         case 0:
-          _context2.next = 2;
-          return sourceRoom(did, botUrl, accessToken, groupUsers);
-        case 2:
-          createRoomResponse = _context2.sent;
-          console.log('createRoomResponse', createRoomResponse);
+          _context2.n = 1;
+          return sourceRoom(did, botUrl, openIdToken, authDid, groupUsers);
+        case 1:
+          createRoomResponse = _context2.v;
           if (createRoomResponse.roomId) {
-            _context2.next = 6;
+            _context2.n = 2;
             break;
           }
           throw new Error('Room ID not found');
-        case 6:
+        case 2:
           roomId = createRoomResponse.roomId;
-          _context2.next = 9;
+          _context2.n = 3;
           return (0, _v1beta.join)(roomId, homeServerUrl, accessToken);
-        case 9:
-          joinRoomResponse = _context2.sent;
+        case 3:
+          joinRoomResponse = _context2.v;
           if (joinRoomResponse.room_id) {
-            _context2.next = 12;
+            _context2.n = 4;
             break;
           }
           throw new Error('Failed to join created room');
-        case 12:
+        case 4:
           if (!(joinRoomResponse.room_id !== roomId)) {
-            _context2.next = 14;
+            _context2.n = 5;
             break;
           }
           throw new Error('Joined room ID does not match created room ID');
-        case 14:
-          return _context2.abrupt("return", createRoomResponse);
-        case 15:
-        case "end":
-          return _context2.stop();
+        case 5:
+          return _context2.a(2, createRoomResponse);
       }
@@ -112,12 +105,12 @@ }, _callee2);
 }
-function roomInvite(_x0, _x1, _x10, _x11) {
+function roomInvite(_x11, _x12, _x13, _x14, _x15) {
   return _roomInvite.apply(this, arguments);
 }
 function _roomInvite() {
-  _roomInvite = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee3(did, botUrl, accessToken, groupUsers) {
+  _roomInvite = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee3(did, botUrl, openIdToken, authDid, groupUsers) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee3$(_context3) {
-      while (1) switch (_context3.prev = _context3.next) {
+    return _regenerator().w(function (_context3) {
+      while (1) switch (_context3.n) {
         case 0:
-          url = "".concat(botUrl, "/room/invite");
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/room/invite"));
           payload = {
@@ -127,28 +120,22 @@ did: did,
           };
-          _context3.next = 4;
+          _context3.n = 1;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: "Bearer ".concat(accessToken)
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 4:
-          response = _context3.sent;
+        case 1:
+          response = _context3.v;
           if (response.ok) {
-            _context3.next = 8;
+            _context3.n = 2;
             break;
           }
-          _context3.next = 8;
+          _context3.n = 2;
           return (0, _error.throwResponseError)(response);
-        case 8:
-          _context3.next = 10;
+        case 2:
+          _context3.n = 3;
           return response.json();
-        case 10:
-          data = _context3.sent;
-          return _context3.abrupt("return", data);
-        case 12:
-        case "end":
-          return _context3.stop();
+        case 3:
+          data = _context3.v;
+          return _context3.a(2, data);
       }
@@ -159,42 +146,39 @@ }, _callee3);
 }
-function roomInviteAndJoin(_x12, _x13, _x14, _x15, _x16) {
+function roomInviteAndJoin(_x16, _x17, _x18, _x19, _x20, _x21, _x22) {
   return _roomInviteAndJoin.apply(this, arguments);
 }
 function _roomInviteAndJoin() {
-  _roomInviteAndJoin = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee4(did, homeServerUrl, botUrl, accessToken, groupUsers) {
+  _roomInviteAndJoin = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee4(did, homeServerUrl, botUrl, openIdToken, authDid, accessToken, groupUsers) {
     var roomInviteResponse, roomId, joinRoomResponse;
-    return _regenerator["default"].wrap(function _callee4$(_context4) {
-      while (1) switch (_context4.prev = _context4.next) {
+    return _regenerator().w(function (_context4) {
+      while (1) switch (_context4.n) {
         case 0:
-          _context4.next = 2;
-          return roomInvite(did, botUrl, accessToken, groupUsers);
-        case 2:
-          roomInviteResponse = _context4.sent;
+          _context4.n = 1;
+          return roomInvite(did, botUrl, openIdToken, authDid, groupUsers);
+        case 1:
+          roomInviteResponse = _context4.v;
           if (roomInviteResponse.roomId) {
-            _context4.next = 5;
+            _context4.n = 2;
             break;
           }
           throw new Error('Room ID not found');
-        case 5:
+        case 2:
           roomId = roomInviteResponse.roomId;
-          _context4.next = 8;
+          _context4.n = 3;
           return (0, _v1beta.join)(roomId, homeServerUrl, accessToken);
-        case 8:
-          joinRoomResponse = _context4.sent;
+        case 3:
+          joinRoomResponse = _context4.v;
           if (joinRoomResponse.room_id) {
-            _context4.next = 11;
+            _context4.n = 4;
             break;
           }
           throw new Error('Failed to join room invite');
-        case 11:
+        case 4:
           if (!(joinRoomResponse.room_id !== roomId)) {
-            _context4.next = 13;
+            _context4.n = 5;
             break;
           }
-          throw new Error('Joined room ID does not invited room ID');
-        case 13:
-          return _context4.abrupt("return", roomInviteResponse);
-        case 14:
-        case "end":
-          return _context4.stop();
+          throw new Error('Joined room ID does not match invited room ID');
+        case 5:
+          return _context4.a(2, roomInviteResponse);
       }
@@ -201,0 +185,0 @@ }, _callee4);

main/stateBot/acl/v1beta1.js

@@ -9,3 +9,2 @@ "use strict";
 exports.setAcl = setAcl;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
@@ -15,18 +14,22 @@ var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _validators = require("../../utils/validators");
-function queryAcl(_x, _x2, _x3, _x4, _x5) {
+var _url = require("../../utils/url");
+var _headers = require("../../utils/headers");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
+function queryAcl(_x, _x2, _x3, _x4, _x5, _x6) {
   return _queryAcl.apply(this, arguments);
 }
 function _queryAcl() {
-  _queryAcl = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(roomId, key, path, botUrl, accessToken) {
+  _queryAcl = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(roomId, key, path, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context.next = 2;
+            _context.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/action");
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -40,28 +43,22 @@ action: 'get-acl',
           };
-          _context.next = 6;
+          _context.n = 2;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: accessToken ? "Bearer ".concat(accessToken) : undefined
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 6:
-          response = _context.sent;
+        case 2:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 10;
+            _context.n = 3;
             break;
           }
-          _context.next = 10;
+          _context.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context.next = 12;
+        case 3:
+          _context.n = 4;
           return response.json();
-        case 12:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context.stop();
+        case 4:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -72,18 +69,18 @@ }, _callee);
 }
-function setAcl(_x6, _x7, _x8, _x9, _x0, _x1) {
+function setAcl(_x7, _x8, _x9, _x0, _x1, _x10, _x11) {
   return _setAcl.apply(this, arguments);
 }
 function _setAcl() {
-  _setAcl = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(roomId, key, path, value, botUrl, accessToken) {
+  _setAcl = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(roomId, key, path, value, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context2.next = 2;
+            _context2.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/action");
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -98,28 +95,22 @@ action: 'set-acl',
           };
-          _context2.next = 6;
+          _context2.n = 2;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: accessToken ? "Bearer ".concat(accessToken) : undefined
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 6:
-          response = _context2.sent;
+        case 2:
+          response = _context2.v;
           if (response.ok) {
-            _context2.next = 10;
+            _context2.n = 3;
             break;
           }
-          _context2.next = 10;
+          _context2.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context2.next = 12;
+        case 3:
+          _context2.n = 4;
           return response.json();
-        case 12:
-          data = _context2.sent;
-          return _context2.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context2.stop();
+        case 4:
+          data = _context2.v;
+          return _context2.a(2, data);
       }
@@ -126,0 +117,0 @@ }, _callee2);

main/stateBot/index.js

 "use strict";
 
-var _typeof = require("@babel/runtime/helpers/typeof");
 Object.defineProperty(exports, "__esModule", {
@@ -8,32 +7,17 @@ value: true
 exports.createMatrixStateBotClient = createMatrixStateBotClient;
-var _1 = _interopRequireWildcard(require("./acl/v1beta1"));
-var _2 = _interopRequireWildcard(require("./bot/v1beta1"));
-var _3 = _interopRequireWildcard(require("./state/v1beta1"));
-function _interopRequireWildcard(e, t) { if ("function" == typeof WeakMap) var r = new WeakMap(), n = new WeakMap(); return (_interopRequireWildcard = function _interopRequireWildcard(e, t) { if (!t && e && e.__esModule) return e; var o, i, f = { __proto__: null, "default": e }; if (null === e || "object" != _typeof(e) && "function" != typeof e) return f; if (o = t ? n : r) { if (o.has(e)) return o.get(e); o.set(e, f); } for (var _t in e) "default" !== _t && {}.hasOwnProperty.call(e, _t) && ((i = (o = Object.defineProperty) && Object.getOwnPropertyDescriptor(e, _t)) && (i.get || i.set) ? o(f, _t, i) : f[_t] = e[_t]); return f; })(e, t); }
-var stateBot;
-(function (_stateBot) {
-  var acl;
-  (function (_acl) {
-    var v1beta1 = _acl.v1beta1 = _1;
-  })(acl || (acl = _stateBot.acl || (_stateBot.acl = {})));
-  var bot;
-  (function (_bot) {
-    var v1beta1 = _bot.v1beta1 = _2;
-  })(bot || (bot = _stateBot.bot || (_stateBot.bot = {})));
-  var state;
-  (function (_state) {
-    var v1beta1 = _state.v1beta1 = _3;
-  })(state || (state = _stateBot.state || (_stateBot.state = {})));
-})(stateBot || (stateBot = {}));
+var _v1beta = require("./acl/v1beta1");
+var _v1beta2 = require("./state/v1beta1");
+var _v1beta3 = require("../bot/v1beta1");
 function createMatrixStateBotClient(_ref) {
   var botUrl = _ref.botUrl,
-    accessToken = _ref.accessToken;
+    accessToken = _ref.accessToken,
+    homeServerUrl = _ref.homeServerUrl;
   return {
     acl: {
       v1beta1: {
-        queryAcl: function queryAcl(roomId, key, path, overrideBotUrl, overrideAccessToken) {
-          return stateBot.acl.v1beta1.queryAcl(roomId, key, path, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        queryAcl: function queryAcl(roomId, key, path, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.queryAcl)(roomId, key, path, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        setAcl: function setAcl(roomId, key, path, value, overrideBotUrl, overrideAccessToken) {
-          return stateBot.acl.v1beta1.setAcl(roomId, key, path, value, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        setAcl: function setAcl(roomId, key, path, value, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta.setAcl)(roomId, key, path, value, overrideBotUrl || botUrl, openIdToken, authDid);
         }
@@ -44,4 +28,10 @@ }
       v1beta1: {
-        invite: function invite(roomId, overrideBotUrl, overrideAccessToken) {
-          return stateBot.bot.v1beta1.invite(roomId, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        invite: function invite(roomId) {
+          return (0, _v1beta3.invite)(roomId, botUrl, homeServerUrl, accessToken);
+        },
+        invited: function invited(roomId) {
+          return (0, _v1beta3.invited)(roomId, botUrl);
+        },
+        getConfig: function getConfig() {
+          return (0, _v1beta3.getConfig)(botUrl);
         }
@@ -52,7 +42,7 @@ }
       v1beta1: {
-        queryState: function queryState(roomId, key, path, overrideBotUrl, overrideAccessToken) {
-          return stateBot.state.v1beta1.queryState(roomId, key, path, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        queryState: function queryState(roomId, key, path, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta2.queryState)(roomId, key, path, overrideBotUrl || botUrl, openIdToken, authDid);
         },
-        setState: function setState(roomId, key, path, value, overrideBotUrl, overrideAccessToken) {
-          return stateBot.state.v1beta1.setState(roomId, key, path, value, overrideBotUrl || botUrl, overrideAccessToken || accessToken);
+        setState: function setState(roomId, key, path, value, openIdToken, authDid, overrideBotUrl) {
+          return (0, _v1beta2.setState)(roomId, key, path, value, overrideBotUrl || botUrl, openIdToken, authDid);
         }
@@ -59,0 +49,0 @@ }

main/stateBot/state/v1beta1.js

@@ -9,3 +9,2 @@ "use strict";
 exports.setState = setState;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
@@ -15,18 +14,22 @@ var _nodeFetch = _interopRequireDefault(require("node-fetch"));
 var _validators = require("../../utils/validators");
-function queryState(_x, _x2, _x3, _x4, _x5) {
+var _url = require("../../utils/url");
+var _headers = require("../../utils/headers");
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
+function queryState(_x, _x2, _x3, _x4, _x5, _x6) {
   return _queryState.apply(this, arguments);
 }
 function _queryState() {
-  _queryState = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(roomId, key, path, botUrl, accessToken) {
+  _queryState = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(roomId, key, path, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context.next = 2;
+            _context.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/action");
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -40,28 +43,22 @@ action: 'get',
           };
-          _context.next = 6;
+          _context.n = 2;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: accessToken ? "Bearer ".concat(accessToken) : undefined
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 6:
-          response = _context.sent;
+        case 2:
+          response = _context.v;
           if (response.ok) {
-            _context.next = 10;
+            _context.n = 3;
             break;
           }
-          _context.next = 10;
+          _context.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context.next = 12;
+        case 3:
+          _context.n = 4;
           return response.json();
-        case 12:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context.stop();
+        case 4:
+          data = _context.v;
+          return _context.a(2, data);
       }
@@ -72,18 +69,18 @@ }, _callee);
 }
-function setState(_x6, _x7, _x8, _x9, _x0, _x1) {
+function setState(_x7, _x8, _x9, _x0, _x1, _x10, _x11) {
   return _setState.apply(this, arguments);
 }
 function _setState() {
-  _setState = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(roomId, key, path, value, botUrl, accessToken) {
+  _setState = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee2(roomId, key, path, value, botUrl, openIdToken, authDid) {
     var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
+    return _regenerator().w(function (_context2) {
+      while (1) switch (_context2.n) {
         case 0:
           if ((0, _validators.isValidRoomId)(roomId)) {
-            _context2.next = 2;
+            _context2.n = 1;
             break;
           }
           throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/action");
+        case 1:
+          url = (0, _url.cleanUrl)("".concat(botUrl, "/action"));
           payload = {
@@ -98,28 +95,22 @@ action: 'set',
           };
-          _context2.next = 6;
+          _context2.n = 2;
           return (0, _nodeFetch["default"])(url, {
             method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: accessToken ? "Bearer ".concat(accessToken) : undefined
-            },
+            headers: (0, _headers.botRestHeaders)(openIdToken, authDid),
             body: JSON.stringify(payload)
           });
-        case 6:
-          response = _context2.sent;
+        case 2:
+          response = _context2.v;
           if (response.ok) {
-            _context2.next = 10;
+            _context2.n = 3;
             break;
           }
-          _context2.next = 10;
+          _context2.n = 3;
           return (0, _error.throwResponseError)(response);
-        case 10:
-          _context2.next = 12;
+        case 3:
+          _context2.n = 4;
           return response.json();
-        case 12:
-          data = _context2.sent;
-          return _context2.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context2.stop();
+        case 4:
+          data = _context2.v;
+          return _context2.a(2, data);
       }
@@ -126,0 +117,0 @@ }, _callee2);

main/utils/error.js

@@ -9,3 +9,2 @@ "use strict";
 exports.throwResponseError = throwResponseError;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
 var _typeof2 = _interopRequireDefault(require("@babel/runtime/helpers/typeof"));
@@ -20,2 +19,4 @@ var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
 var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
+function _regenerator() { /*! regenerator-runtime -- Copyright (c) 2014-present, Facebook, Inc. -- license (MIT): https://github.com/babel/babel/blob/main/packages/babel-helpers/LICENSE */ var e, t, r = "function" == typeof Symbol ? Symbol : {}, n = r.iterator || "@@iterator", o = r.toStringTag || "@@toStringTag"; function i(r, n, o, i) { var c = n && n.prototype instanceof Generator ? n : Generator, u = Object.create(c.prototype); return _regeneratorDefine2(u, "_invoke", function (r, n, o) { var i, c, u, f = 0, p = o || [], y = !1, G = { p: 0, n: 0, v: e, a: d, f: d.bind(e, 4), d: function d(t, r) { return i = t, c = 0, u = e, G.n = r, a; } }; function d(r, n) { for (c = r, u = n, t = 0; !y && f && !o && t < p.length; t++) { var o, i = p[t], d = G.p, l = i[2]; r > 3 ? (o = l === n) && (u = i[(c = i[4]) ? 5 : (c = 3, 3)], i[4] = i[5] = e) : i[0] <= d && ((o = r < 2 && d < i[1]) ? (c = 0, G.v = n, G.n = i[1]) : d < l && (o = r < 3 || i[0] > n || n > l) && (i[4] = r, i[5] = n, G.n = l, c = 0)); } if (o || r > 1) return a; throw y = !0, n; } return function (o, p, l) { if (f > 1) throw TypeError("Generator is already running"); for (y && 1 === p && d(p, l), c = p, u = l; (t = c < 2 ? e : u) || !y;) { i || (c ? c < 3 ? (c > 1 && (G.n = -1), d(c, u)) : G.n = u : G.v = u); try { if (f = 2, i) { if (c || (o = "next"), t = i[o]) { if (!(t = t.call(i, u))) throw TypeError("iterator result is not an object"); if (!t.done) return t; u = t.value, c < 2 && (c = 0); } else 1 === c && (t = i["return"]) && t.call(i), c < 2 && (u = TypeError("The iterator does not provide a '" + o + "' method"), c = 1); i = e; } else if ((t = (y = G.n < 0) ? u : r.call(n, G)) !== a) break; } catch (t) { i = e, c = 1, u = t; } finally { f = 1; } } return { value: t, done: y }; }; }(r, o, i), !0), u; } var a = {}; function Generator() {} function GeneratorFunction() {} function GeneratorFunctionPrototype() {} t = Object.getPrototypeOf; var c = [][n] ? t(t([][n]())) : (_regeneratorDefine2(t = {}, n, function () { return this; }), t), u = GeneratorFunctionPrototype.prototype = Generator.prototype = Object.create(c); function f(e) { return Object.setPrototypeOf ? Object.setPrototypeOf(e, GeneratorFunctionPrototype) : (e.__proto__ = GeneratorFunctionPrototype, _regeneratorDefine2(e, o, "GeneratorFunction")), e.prototype = Object.create(u), e; } return GeneratorFunction.prototype = GeneratorFunctionPrototype, _regeneratorDefine2(u, "constructor", GeneratorFunctionPrototype), _regeneratorDefine2(GeneratorFunctionPrototype, "constructor", GeneratorFunction), GeneratorFunction.displayName = "GeneratorFunction", _regeneratorDefine2(GeneratorFunctionPrototype, o, "GeneratorFunction"), _regeneratorDefine2(u), _regeneratorDefine2(u, o, "Generator"), _regeneratorDefine2(u, n, function () { return this; }), _regeneratorDefine2(u, "toString", function () { return "[object Generator]"; }), (_regenerator = function _regenerator() { return { w: i, m: f }; })(); }
+function _regeneratorDefine2(e, r, n, t) { var i = Object.defineProperty; try { i({}, "", {}); } catch (e) { i = 0; } _regeneratorDefine2 = function _regeneratorDefine(e, r, n, t) { function o(r, n) { _regeneratorDefine2(e, r, function (e) { return this._invoke(r, n, e); }); } r ? i ? i(e, r, { value: n, enumerable: !t, configurable: !t, writable: !t }) : e[r] = n : (o("next", 0), o("throw", 1), o("return", 2)); }, _regeneratorDefine2(e, r, n, t); }
 function _callSuper(t, o, e) { return o = (0, _getPrototypeOf2["default"])(o), (0, _possibleConstructorReturn2["default"])(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], (0, _getPrototypeOf2["default"])(t).constructor) : o.apply(t, e)); }
@@ -43,69 +44,68 @@ function _isNativeReflectConstruct() { try { var t = !Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); } catch (t) {} return (_isNativeReflectConstruct = function _isNativeReflectConstruct() { return !!t; })(); }
 function _throwResponseError() {
-  _throwResponseError = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(response) {
+  _throwResponseError = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator().m(function _callee(response) {
     var data, text;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
+    return _regenerator().w(function (_context) {
+      while (1) switch (_context.n) {
         case 0:
-          _context.next = 2;
+          _context.n = 1;
           return response.json()["catch"](function () {
             return null;
           });
-        case 2:
-          data = _context.sent;
+        case 1:
+          data = _context.v;
           if (!(data !== undefined && data !== null)) {
-            _context.next = 16;
+            _context.n = 7;
             break;
           }
           if (!(data !== null && data !== void 0 && data.error)) {
-            _context.next = 6;
+            _context.n = 2;
             break;
           }
           throw new MatrixBotError(data.error, data.errcode);
-        case 6:
+        case 2:
           if (!(data !== null && data !== void 0 && data.message)) {
-            _context.next = 8;
+            _context.n = 3;
             break;
           }
           throw new MatrixBotError(data.message, data.errcode);
-        case 8:
+        case 3:
           if (!(data !== null && data !== void 0 && data.errcode)) {
-            _context.next = 10;
+            _context.n = 4;
             break;
           }
           throw new MatrixBotError(data.errcode, data.errcode);
-        case 10:
+        case 4:
           if (!(typeof data === 'string')) {
-            _context.next = 12;
+            _context.n = 5;
             break;
           }
           throw new MatrixBotError(data);
-        case 12:
+        case 5:
           if (!((0, _typeof2["default"])(data) === 'object')) {
-            _context.next = 14;
+            _context.n = 6;
             break;
           }
           throw new MatrixBotError(JSON.stringify(data));
-        case 14:
+        case 6:
           if (!(data !== null && data !== void 0 && data.toString && typeof data.toString === 'function')) {
-            _context.next = 16;
+            _context.n = 7;
             break;
           }
           throw new MatrixBotError(data.toString());
-        case 16:
-          _context.next = 18;
+        case 7:
+          _context.n = 8;
           return response.text()["catch"](function () {
             return null;
           });
-        case 18:
-          text = _context.sent;
+        case 8:
+          text = _context.v;
           if (!text) {
-            _context.next = 21;
+            _context.n = 9;
             break;
           }
           throw new MatrixBotError(text);
-        case 21:
+        case 9:
           throw new MatrixBotError(response.statusText);
-        case 22:
-        case "end":
-          return _context.stop();
+        case 10:
+          return _context.a(2);
       }
@@ -112,0 +112,0 @@ }, _callee);

main/utils/index.js

@@ -7,5 +7,12 @@ "use strict";
 });
+Object.defineProperty(exports, "botRestHeaders", {
+  enumerable: true,
+  get: function get() {
+    return _headers.botRestHeaders;
+  }
+});
 exports.utils = void 0;
 var _1 = _interopRequireWildcard(require("./mxc"));
 var _2 = _interopRequireWildcard(require("./validators"));
+var _headers = require("./headers");
 function _interopRequireWildcard(e, t) { if ("function" == typeof WeakMap) var r = new WeakMap(), n = new WeakMap(); return (_interopRequireWildcard = function _interopRequireWildcard(e, t) { if (!t && e && e.__esModule) return e; var o, i, f = { __proto__: null, "default": e }; if (null === e || "object" != _typeof(e) && "function" != typeof e) return f; if (o = t ? n : r) { if (o.has(e)) return o.get(e); o.set(e, f); } for (var _t in e) "default" !== _t && {}.hasOwnProperty.call(e, _t) && ((i = (o = Object.defineProperty) && Object.getOwnPropertyDescriptor(e, _t)) && (i.get || i.set) ? o(f, _t, i) : f[_t] = e[_t]); return f; })(e, t); }
@@ -12,0 +19,0 @@ var utils;

main/utils/url.js

@@ -8,19 +8,3 @@ "use strict";
 function cleanUrl(url) {
-  // Remove line breakers such as \n and any other whitespace characters
-  var cleanUrl = url.replace(/[\n\r\s]/g, '');
-
-  // Regular expression to match duplicate slashes except for the first one after "https://" or "http://"
-  var regex = /(https?:\/\/|[^:])\/\//g;
-
-  // Replace duplicate slashes with a single slash, excluding the first one after "https://" or "http://"
-  cleanUrl = cleanUrl.replace(regex, function (match, p1, offset, string) {
-    // If match starts with http: or https:, keep it as it is.
-    if (p1 === 'http://' || p1 === 'https://') {
-      return match;
-    } else {
-      // Otherwise, replace the extra slashes with a single slash
-      return p1 + '/';
-    }
-  });
-  return cleanUrl;
+  return url.replace(/([^:]\/)\/+/g, '$1');
 }

module/api/account/v1beta1.js

 import fetch from 'node-fetch';
 import { throwResponseError } from '../../utils/error';
+import { cleanUrl } from '../../utils/url';
 export async function queryWhoAmI(homeServerUrl, accessToken) {
@@ -7,6 +8,7 @@ if (!accessToken) {
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/account/whoami`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/account/whoami`);
   const response = await fetch(url, {
     method: 'GET',
     headers: {
+      'Content-Type': 'application/json',
       Authorization: `Bearer ${accessToken}`
@@ -20,2 +22,26 @@ }
   return data;
+}
+export async function queryUsernameAvailable(username, homeServerUrl, accessToken) {
+  if (!username) {
+    throw new Error('Username cannot be empty');
+  }
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/register/available?username=${encodeURIComponent(username)}`);
+  const response = await fetch(url, {
+    method: 'GET',
+    headers: {
+      'Content-Type': 'application/json',
+      Authorization: `Bearer ${accessToken}`
+    }
+  });
+  if (!response.ok) {
+    try {
+      const data = await response.json();
+      if ((data === null || data === void 0 ? void 0 : data.errcode) === 'M_USER_IN_USE') {
+        return false;
+      }
+    } catch {}
+    await throwResponseError(response);
+  }
+  const data = await response.json();
+  return data === null || data === void 0 ? void 0 : data.available;
 }

module/api/event/v1beta1.js

 import fetch from 'node-fetch';
 import { throwResponseError } from '../../utils/error';
 import { isValidEventId, isValidEventType, isValidRoomId } from '../../utils/validators';
+import { cleanUrl } from '../../utils/url';
 export async function queryEvent(roomId, eventId, homeServerUrl, accessToken) {
@@ -12,3 +13,3 @@ console.log('queryEvent', roomId, eventId, homeServerUrl, accessToken);
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/event/${encodeURIComponent(eventId)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/event/${encodeURIComponent(eventId)}`);
   const response = await fetch(url, {
@@ -34,3 +35,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v1/rooms/${encodeURIComponent(roomId)}/relations/${encodeURIComponent(parentEventId)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v1/rooms/${encodeURIComponent(roomId)}/relations/${encodeURIComponent(parentEventId)}`);
   const response = await fetch(url, {
@@ -56,3 +57,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v1/rooms/${encodeURIComponent(roomId)}/relations/${encodeURIComponent(parentEventId)}/${encodeURIComponent(relType)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v1/rooms/${encodeURIComponent(roomId)}/relations/${encodeURIComponent(parentEventId)}/${encodeURIComponent(relType)}`);
   const response = await fetch(url, {
@@ -81,3 +82,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v1/rooms/${encodeURIComponent(roomId)}/relations/${encodeURIComponent(parentEventId)}/${encodeURIComponent(relType)}/${encodeURIComponent(eventType)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v1/rooms/${encodeURIComponent(roomId)}/relations/${encodeURIComponent(parentEventId)}/${encodeURIComponent(relType)}/${encodeURIComponent(eventType)}`);
   const response = await fetch(url, {
@@ -84,0 +85,0 @@ method: 'GET',

module/api/index.js

@@ -50,3 +50,4 @@ import * as _1 from './media/v1beta1';
       v1beta1: {
-        queryWhoAmI: (overrideHomeServerUrl, overrideAccessToken) => api.account.v1beta1.queryWhoAmI(overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken)
+        queryWhoAmI: (overrideHomeServerUrl, overrideAccessToken) => api.account.v1beta1.queryWhoAmI(overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken),
+        queryUsernameAvailable: (username, overrideHomeServerUrl, overrideAccessToken) => api.account.v1beta1.queryUsernameAvailable(username, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken)
       }
@@ -64,3 +65,6 @@ },
         leave: (roomId, reason, overrideHomeServerUrl, overrideAccessToken) => api.room.v1beta1.leave(roomId, reason, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken),
-        kick: (roomId, userId, reason, overrideHomeServerUrl, overrideAccessToken) => api.room.v1beta1.kick(roomId, userId, reason, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken)
+        kick: (roomId, userId, reason, overrideHomeServerUrl, overrideAccessToken) => api.room.v1beta1.kick(roomId, userId, reason, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken),
+        inviteUser: (roomId, userId, overrideHomeServerUrl, overrideAccessToken) => api.room.v1beta1.inviteUser(roomId, userId, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken),
+        getPowerLevels: (roomId, overrideHomeServerUrl, overrideAccessToken) => api.room.v1beta1.getPowerLevels(roomId, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken),
+        setPowerLevels: (roomId, content, overrideHomeServerUrl, overrideAccessToken) => api.room.v1beta1.setPowerLevels(roomId, content, overrideHomeServerUrl || homeServerUrl, overrideAccessToken || accessToken)
       }
@@ -67,0 +71,0 @@ },

module/api/media/v1beta1.js

@@ -36,6 +36,5 @@ import fetch from 'node-fetch';
   }
-  let url = `${homeServerUrl}/_matrix/media/v3/upload`;
-  url = cleanUrl(url);
+  let url = cleanUrl(`${homeServerUrl}/_matrix/media/v3/upload`);
   url += `?filename=${encodeURIComponent(filename)}`;
-  const response = await fetch(cleanUrl(url), {
+  const response = await fetch(url, {
     method: 'POST',
@@ -42,0 +41,0 @@ headers: {

module/api/profile/v1beta1.js

 import fetch from 'node-fetch';
 import { throwResponseError } from '../../utils/error';
 import { isValidMxcLink, isValidUserId } from '../../utils/validators';
+import { cleanUrl } from '../../utils/url';
 export async function queryProfile(userId, homeServerUrl, accessToken) {
@@ -8,3 +9,3 @@ if (!isValidUserId(userId)) {
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}`);
   const response = await fetch(url, {
@@ -27,3 +28,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}/displayname`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}/displayname`);
   const response = await fetch(url, {
@@ -46,3 +47,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}/avatar_url`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}/avatar_url`);
   const response = await fetch(url, {
@@ -72,3 +73,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}/displayname`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}/displayname`);
   const response = await fetch(url, {
@@ -104,3 +105,3 @@ method: 'PUT',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}/avatar_url`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/profile/${encodeURIComponent(userId)}/avatar_url`);
   const response = await fetch(url, {
@@ -107,0 +108,0 @@ method: 'PUT',

module/api/room/v1beta1.js

 import fetch from 'node-fetch';
 import { throwResponseError } from '../../utils/error';
 import { isValidRoomAlias, isValidRoomId, isValidUserId } from '../../utils/validators';
+import { cleanUrl } from '../../utils/url';
 export async function queryId(alias, homeServerUrl, accessToken) {
@@ -8,3 +9,3 @@ if (!isValidRoomAlias(alias)) {
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/directory/room/${encodeURIComponent(alias)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/directory/room/${encodeURIComponent(alias)}`);
   const response = await fetch(url, {
@@ -27,3 +28,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/directory/list/room/${encodeURIComponent(roomId)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/directory/list/room/${encodeURIComponent(roomId)}`);
   const response = await fetch(url, {
@@ -46,3 +47,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/directory/list/room/${encodeURIComponent(roomId)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/directory/list/room/${encodeURIComponent(roomId)}`);
   const payload = {
@@ -69,3 +70,3 @@ visibility: visibility
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/knock/${encodeURIComponent(roomIdOrAlias)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/knock/${encodeURIComponent(roomIdOrAlias)}`);
   const response = await fetch(url, {
@@ -88,3 +89,3 @@ method: 'POST',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/join/${encodeURIComponent(roomIdOrAlias)}`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/join/${encodeURIComponent(roomIdOrAlias)}`);
   const response = await fetch(url, {
@@ -104,3 +105,3 @@ method: 'POST',
 export async function listJoinedRooms(homeServerUrl, accessToken) {
-  const url = `${homeServerUrl}/_matrix/client/v3/joined_rooms`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/joined_rooms`);
   const response = await fetch(url, {
@@ -123,3 +124,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/joined_members`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/joined_members`);
   const response = await fetch(url, {
@@ -142,3 +143,3 @@ method: 'GET',
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/leave`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/leave`);
   const payload = {
@@ -168,3 +169,3 @@ reason: reason
   }
-  const url = `${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/kick`;
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/kick`);
   const payload = {
@@ -187,2 +188,64 @@ user_id: userId,
   return data;
+}
+export async function inviteUser(roomId, userId, homeServerUrl, accessToken) {
+  if (!isValidRoomId(roomId)) {
+    throw new Error('Invalid room ID');
+  }
+  if (!isValidUserId(userId)) {
+    throw new Error('Invalid user ID');
+  }
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/invite`);
+  const payload = {
+    user_id: userId
+  };
+  const response = await fetch(url, {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+      Authorization: `Bearer ${accessToken}`
+    },
+    body: JSON.stringify(payload)
+  });
+  if (!response.ok) {
+    await throwResponseError(response);
+  }
+  const data = await response.json();
+  return data;
+}
+export async function getPowerLevels(roomId, homeServerUrl, accessToken) {
+  if (!isValidRoomId(roomId)) {
+    throw new Error('Invalid room ID');
+  }
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/state/m.room.power_levels/`);
+  const response = await fetch(url, {
+    method: 'GET',
+    headers: {
+      'Content-Type': 'application/json',
+      Authorization: `Bearer ${accessToken}`
+    }
+  });
+  if (!response.ok) {
+    await throwResponseError(response);
+  }
+  const data = await response.json();
+  return data;
+}
+export async function setPowerLevels(roomId, content, homeServerUrl, accessToken) {
+  if (!isValidRoomId(roomId)) {
+    throw new Error('Invalid room ID');
+  }
+  const url = cleanUrl(`${homeServerUrl}/_matrix/client/v3/rooms/${encodeURIComponent(roomId)}/state/m.room.power_levels/`);
+  const response = await fetch(url, {
+    method: 'PUT',
+    headers: {
+      'Content-Type': 'application/json',
+      Authorization: `Bearer ${accessToken}`
+    },
+    body: JSON.stringify(content)
+  });
+  if (!response.ok) {
+    await throwResponseError(response);
+  }
+  const data = await response.json();
+  return data;
 }

module/bidBot/bid/v1beta1.js

@@ -7,7 +7,9 @@ import _defineProperty from "@babel/runtime/helpers/esm/defineProperty";
 import { isValidBidRole, isValidCollectionId, isValidDid, isValidEventId } from '../../utils/validators';
-export async function queryBids(collection, pagination, botUrl, accessToken) {
+import { cleanUrl } from '../../utils/url';
+import { botRestHeaders } from '../../utils/headers';
+export async function queryBids(collection, pagination, botUrl, openIdToken, authDid) {
   if (!isValidCollectionId(collection)) {
     throw new Error('Invalid collection ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -23,6 +25,3 @@ action: 'get-bids',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -36,3 +35,3 @@ });
 }
-export async function queryBidsByDid(collection, did, botUrl, accessToken) {
+export async function queryBidsByDid(collection, did, botUrl, openIdToken, authDid) {
   if (!isValidCollectionId(collection)) {
@@ -44,3 +43,3 @@ throw new Error('Invalid collection ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -55,6 +54,3 @@ action: 'get-bids-by-did',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -68,3 +64,3 @@ });
 }
-export async function submitBid(collection, bid, role, botUrl, accessToken) {
+export async function submitBid(collection, bid, role, botUrl, openIdToken, authDid) {
   if (!isValidCollectionId(collection)) {
@@ -76,3 +72,3 @@ throw new Error('Invalid collection ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -88,6 +84,3 @@ action: 'submit-bid',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -101,3 +94,3 @@ });
 }
-export async function approveBid(bidId, collection, did, botUrl, accessToken) {
+export async function approveBid(bidId, collection, did, botUrl, openIdToken, authDid) {
   if (!isValidEventId(bidId)) {
@@ -112,3 +105,3 @@ throw new Error('Invalid bid ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -125,6 +118,3 @@ action: 'evaluate-bid',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -138,3 +128,3 @@ });
 }
-export async function rejectBid(bidId, collection, did, reason, botUrl, accessToken) {
+export async function rejectBid(bidId, collection, did, reason, botUrl, openIdToken, authDid) {
   if (!isValidEventId(bidId)) {
@@ -149,3 +139,3 @@ throw new Error('Invalid bid ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -165,6 +155,3 @@ action: 'evaluate-bid',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -178,3 +165,3 @@ });
 }
-export async function queryDidIsBlocked(collection, did, botUrl, accessToken) {
+export async function queryDidIsBlocked(collection, did, botUrl, openIdToken, authDid) {
   if (!isValidCollectionId(collection)) {
@@ -186,3 +173,3 @@ throw new Error('Invalid collection ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -197,6 +184,3 @@ action: 'did-is-blocked',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -210,3 +194,3 @@ });
 }
-export async function didBlock(collection, did, botUrl, accessToken) {
+export async function didBlock(collection, did, botUrl, openIdToken, authDid) {
   if (!isValidCollectionId(collection)) {
@@ -218,3 +202,3 @@ throw new Error('Invalid collection ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -229,6 +213,3 @@ action: 'did-block',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -242,3 +223,3 @@ });
 }
-export async function didUnblock(collection, did, botUrl, accessToken) {
+export async function didUnblock(collection, did, botUrl, openIdToken, authDid) {
   if (!isValidCollectionId(collection)) {
@@ -250,3 +231,3 @@ throw new Error('Invalid collection ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -261,6 +242,3 @@ action: 'did-unblock',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -267,0 +245,0 @@ });

module/bidBot/index.js

@@ -1,17 +0,7 @@
-import * as _1 from './bid/v1beta1';
-import * as _2 from './bot/v1beta1';
-let bidBot;
-(function (_bidBot) {
-  let bid;
-  (function (_bid) {
-    const v1beta1 = _bid.v1beta1 = _1;
-  })(bid || (bid = _bidBot.bid || (_bidBot.bid = {})));
-  let bot;
-  (function (_bot) {
-    const v1beta1 = _bot.v1beta1 = _2;
-  })(bot || (bot = _bidBot.bot || (_bidBot.bot = {})));
-})(bidBot || (bidBot = {}));
+import { queryBids, queryBidsByDid, submitBid, approveBid, rejectBid, queryDidIsBlocked, didBlock, didUnblock } from './bid/v1beta1';
+import { invite, invited, getConfig } from '../bot/v1beta1';
 export function createMatrixBidBotClient({
   botUrl,
-  accessToken
+  accessToken,
+  homeServerUrl
 }) {
@@ -21,10 +11,10 @@ return {
       v1beta1: {
-        queryBids: (collection, pagination, overrideBotUrl, overrideAccessToken) => bidBot.bid.v1beta1.queryBids(collection, pagination, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        queryBidsByDid: (collection, did, overrideBotUrl, overrideAccessToken) => bidBot.bid.v1beta1.queryBidsByDid(collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        submitBid: (collection, did, role, overrideBotUrl, overrideAccessToken) => bidBot.bid.v1beta1.submitBid(collection, did, role, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        approveBid: (bidId, collection, did, overrideBotUrl, overrideAccessToken) => bidBot.bid.v1beta1.approveBid(bidId, collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        rejectBid: (bidId, collection, did, reason, overrideBotUrl, overrideAccessToken) => bidBot.bid.v1beta1.rejectBid(bidId, collection, did, reason, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        queryDidIsBlocked: (collection, did, overrideBotUrl, overrideAccessToken) => bidBot.bid.v1beta1.queryDidIsBlocked(collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        didBlock: (collection, did, overrideBotUrl, overrideAccessToken) => bidBot.bid.v1beta1.didBlock(collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        didUnblock: (collection, did, overrideBotUrl, overrideAccessToken) => bidBot.bid.v1beta1.didUnblock(collection, did, overrideBotUrl || botUrl, overrideAccessToken || accessToken)
+        queryBids: (collection, openIdToken, authDid, pagination, overrideBotUrl) => queryBids(collection, pagination, overrideBotUrl || botUrl, openIdToken, authDid),
+        queryBidsByDid: (collection, did, openIdToken, authDid, overrideBotUrl) => queryBidsByDid(collection, did, overrideBotUrl || botUrl, openIdToken, authDid),
+        submitBid: (collection, bid, role, openIdToken, authDid, overrideBotUrl) => submitBid(collection, bid, role, overrideBotUrl || botUrl, openIdToken, authDid),
+        approveBid: (bidId, collection, did, openIdToken, authDid, overrideBotUrl) => approveBid(bidId, collection, did, overrideBotUrl || botUrl, openIdToken, authDid),
+        rejectBid: (bidId, collection, did, reason, openIdToken, authDid, overrideBotUrl) => rejectBid(bidId, collection, did, reason, overrideBotUrl || botUrl, openIdToken, authDid),
+        queryDidIsBlocked: (collection, did, openIdToken, authDid, overrideBotUrl) => queryDidIsBlocked(collection, did, overrideBotUrl || botUrl, openIdToken, authDid),
+        didBlock: (collection, did, openIdToken, authDid, overrideBotUrl) => didBlock(collection, did, overrideBotUrl || botUrl, openIdToken, authDid),
+        didUnblock: (collection, did, openIdToken, authDid, overrideBotUrl) => didUnblock(collection, did, overrideBotUrl || botUrl, openIdToken, authDid)
       }
@@ -34,4 +24,5 @@ },
       v1beta1: {
-        invite: roomId => bidBot.bot.v1beta1.invite(roomId, botUrl, accessToken),
-        invited: roomId => bidBot.bot.v1beta1.invited(roomId, botUrl)
+        invite: roomId => invite(roomId, botUrl, homeServerUrl, accessToken),
+        invited: roomId => invited(roomId, botUrl),
+        getConfig: () => getConfig(botUrl)
       }
@@ -38,0 +29,0 @@ }

module/claimBot/claim/v1beta1.js

 import fetch from 'node-fetch';
 import { throwResponseError } from '../../utils/error';
 import { isValidCollectionId } from '../../utils/validators';
-export async function queryClaim(collection, cid, botUrl, accessToken) {
+import { cleanUrl } from '../../utils/url';
+import { botRestHeaders } from '../../utils/headers';
+export async function queryClaim(collection, cid, botUrl, openIdToken, authDid) {
   if (!isValidCollectionId(collection)) {
     throw new Error('Invalid collection ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -18,6 +20,3 @@ action: 'get-claim',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -31,7 +30,7 @@ });
 }
-export async function saveClaim(collection, claim, botUrl, accessToken) {
+export async function saveClaim(collection, claim, botUrl, openIdToken, authDid) {
   if (!isValidCollectionId(collection)) {
     throw new Error('Invalid collection ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -46,6 +45,3 @@ action: 'save-claim',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -52,0 +48,0 @@ });

module/claimBot/index.js

@@ -1,17 +0,7 @@
-import * as _1 from './claim/v1beta1';
-import * as _2 from './bot/v1beta1';
-let claimBot;
-(function (_claimBot) {
-  let claim;
-  (function (_claim) {
-    const v1beta1 = _claim.v1beta1 = _1;
-  })(claim || (claim = _claimBot.claim || (_claimBot.claim = {})));
-  let bot;
-  (function (_bot) {
-    const v1beta1 = _bot.v1beta1 = _2;
-  })(bot || (bot = _claimBot.bot || (_claimBot.bot = {})));
-})(claimBot || (claimBot = {}));
+import { queryClaim, saveClaim } from './claim/v1beta1';
+import { invite, invited, getConfig } from '../bot/v1beta1';
 export function createMatrixClaimBotClient({
   botUrl,
-  accessToken
+  accessToken,
+  homeServerUrl
 }) {
@@ -21,4 +11,4 @@ return {
       v1beta1: {
-        queryClaim: (collection, cid) => claimBot.claim.v1beta1.queryClaim(collection, cid, botUrl, accessToken),
-        saveClaim: (collection, claim) => claimBot.claim.v1beta1.saveClaim(collection, claim, botUrl, accessToken)
+        queryClaim: (collection, cid, openIdToken, authDid) => queryClaim(collection, cid, botUrl, openIdToken, authDid),
+        saveClaim: (collection, claim, openIdToken, authDid) => saveClaim(collection, claim, botUrl, openIdToken, authDid)
       }
@@ -28,4 +18,5 @@ },
       v1beta1: {
-        invite: roomId => claimBot.bot.v1beta1.invite(roomId, botUrl, accessToken),
-        invited: roomId => claimBot.bot.v1beta1.invited(roomId, botUrl)
+        invite: roomId => invite(roomId, botUrl, homeServerUrl, accessToken),
+        invited: roomId => invited(roomId, botUrl),
+        getConfig: () => getConfig(botUrl)
       }
@@ -32,0 +23,0 @@ }

module/roomBot/index.js

@@ -17,6 +17,6 @@ import * as _1 from './room/v1beta1';
       v1beta1: {
-        sourceRoom: (did, overrideBotUrl, overrideAccessToken, groupUsers) => roomBot.room.v1beta1.sourceRoom(did, overrideBotUrl || botUrl, overrideAccessToken || accessToken, groupUsers),
-        sourceRoomAndJoin: (did, overrideHomeServerUrl, overrideBotUrl, overrideAccessToken, groupUsers) => roomBot.room.v1beta1.sourceRoomAndJoin(did, overrideHomeServerUrl || homeServerUrl, overrideBotUrl || botUrl, overrideAccessToken || accessToken, groupUsers),
-        roomInvite: (did, overrideBotUrl, overrideAccessToken, groupUsers) => roomBot.room.v1beta1.roomInvite(did, overrideBotUrl || botUrl, overrideAccessToken || accessToken, groupUsers),
-        roomInviteAndJoin: (did, overrideHomeServerUrl, overrideBotUrl, overrideAccessToken, groupUsers) => roomBot.room.v1beta1.roomInviteAndJoin(did, overrideHomeServerUrl || homeServerUrl, overrideBotUrl || botUrl, overrideAccessToken || accessToken, groupUsers)
+        sourceRoom: (did, openIdToken, authDid, overrideBotUrl, groupUsers) => roomBot.room.v1beta1.sourceRoom(did, overrideBotUrl || botUrl, openIdToken, authDid, groupUsers),
+        sourceRoomAndJoin: (did, openIdToken, authDid, overrideHomeServerUrl, overrideBotUrl, overrideAccessToken, groupUsers) => roomBot.room.v1beta1.sourceRoomAndJoin(did, overrideHomeServerUrl || homeServerUrl, overrideBotUrl || botUrl, openIdToken, authDid, overrideAccessToken || accessToken, groupUsers),
+        roomInvite: (did, openIdToken, authDid, overrideBotUrl, groupUsers) => roomBot.room.v1beta1.roomInvite(did, overrideBotUrl || botUrl, openIdToken, authDid, groupUsers),
+        roomInviteAndJoin: (did, openIdToken, authDid, overrideHomeServerUrl, overrideBotUrl, overrideAccessToken, groupUsers) => roomBot.room.v1beta1.roomInviteAndJoin(did, overrideHomeServerUrl || homeServerUrl, overrideBotUrl || botUrl, openIdToken, authDid, overrideAccessToken || accessToken, groupUsers)
       }
@@ -23,0 +23,0 @@ }

module/roomBot/room/v1beta1.js

 import fetch from 'node-fetch';
 import { throwResponseError } from '../../utils/error';
 import { join } from '../../api/room/v1beta1';
-// WIll only create room if not exists yet
-export async function sourceRoom(did, botUrl, accessToken, groupUsers) {
-  const url = `${botUrl}/room/source`;
+import { cleanUrl } from '../../utils/url';
+import { botRestHeaders } from '../../utils/headers';
+// Will only create room if not exists yet
+export async function sourceRoom(did, botUrl, openIdToken, authDid, groupUsers) {
+  const url = cleanUrl(`${botUrl}/room/source`);
   const payload = {
@@ -13,6 +15,3 @@ did: did,
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: accessToken ? `Bearer ${accessToken}` : undefined
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -26,5 +25,4 @@ });
 }
-export async function sourceRoomAndJoin(did, homeServerUrl, botUrl, accessToken, groupUsers) {
-  const createRoomResponse = await sourceRoom(did, botUrl, accessToken, groupUsers);
-  console.log('createRoomResponse', createRoomResponse);
+export async function sourceRoomAndJoin(did, homeServerUrl, botUrl, openIdToken, authDid, accessToken, groupUsers) {
+  const createRoomResponse = await sourceRoom(did, botUrl, openIdToken, authDid, groupUsers);
   if (!createRoomResponse.roomId) {
@@ -43,4 +41,4 @@ throw new Error('Room ID not found');
 }
-export async function roomInvite(did, botUrl, accessToken, groupUsers) {
-  const url = `${botUrl}/room/invite`;
+export async function roomInvite(did, botUrl, openIdToken, authDid, groupUsers) {
+  const url = cleanUrl(`${botUrl}/room/invite`);
   const payload = {
@@ -52,6 +50,3 @@ did: did,
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: `Bearer ${accessToken}`
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -65,4 +60,4 @@ });
 }
-export async function roomInviteAndJoin(did, homeServerUrl, botUrl, accessToken, groupUsers) {
-  const roomInviteResponse = await roomInvite(did, botUrl, accessToken, groupUsers);
+export async function roomInviteAndJoin(did, homeServerUrl, botUrl, openIdToken, authDid, accessToken, groupUsers) {
+  const roomInviteResponse = await roomInvite(did, botUrl, openIdToken, authDid, groupUsers);
   if (!roomInviteResponse.roomId) {
@@ -77,5 +72,5 @@ throw new Error('Room ID not found');
   if (joinRoomResponse.room_id !== roomId) {
-    throw new Error('Joined room ID does not invited room ID');
+    throw new Error('Joined room ID does not match invited room ID');
   }
   return roomInviteResponse;
 }

module/stateBot/acl/v1beta1.js

 import fetch from 'node-fetch';
 import { throwResponseError } from '../../utils/error';
 import { isValidRoomId } from '../../utils/validators';
-export async function queryAcl(roomId, key, path, botUrl, accessToken) {
+import { cleanUrl } from '../../utils/url';
+import { botRestHeaders } from '../../utils/headers';
+export async function queryAcl(roomId, key, path, botUrl, openIdToken, authDid) {
   if (!isValidRoomId(roomId)) {
     throw new Error('Invalid room ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -19,6 +21,3 @@ action: 'get-acl',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: accessToken ? `Bearer ${accessToken}` : undefined
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -32,7 +31,7 @@ });
 }
-export async function setAcl(roomId, key, path, value, botUrl, accessToken) {
+export async function setAcl(roomId, key, path, value, botUrl, openIdToken, authDid) {
   if (!isValidRoomId(roomId)) {
     throw new Error('Invalid room ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -49,6 +48,3 @@ action: 'set-acl',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: accessToken ? `Bearer ${accessToken}` : undefined
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -55,0 +51,0 @@ });

module/stateBot/index.js

@@ -1,22 +0,8 @@
-import * as _1 from './acl/v1beta1';
-import * as _2 from './bot/v1beta1';
-import * as _3 from './state/v1beta1';
-let stateBot;
-(function (_stateBot) {
-  let acl;
-  (function (_acl) {
-    const v1beta1 = _acl.v1beta1 = _1;
-  })(acl || (acl = _stateBot.acl || (_stateBot.acl = {})));
-  let bot;
-  (function (_bot) {
-    const v1beta1 = _bot.v1beta1 = _2;
-  })(bot || (bot = _stateBot.bot || (_stateBot.bot = {})));
-  let state;
-  (function (_state) {
-    const v1beta1 = _state.v1beta1 = _3;
-  })(state || (state = _stateBot.state || (_stateBot.state = {})));
-})(stateBot || (stateBot = {}));
+import { queryAcl, setAcl } from './acl/v1beta1';
+import { queryState, setState } from './state/v1beta1';
+import { invite, invited, getConfig } from '../bot/v1beta1';
 export function createMatrixStateBotClient({
   botUrl,
-  accessToken
+  accessToken,
+  homeServerUrl
 }) {
@@ -26,4 +12,4 @@ return {
       v1beta1: {
-        queryAcl: (roomId, key, path, overrideBotUrl, overrideAccessToken) => stateBot.acl.v1beta1.queryAcl(roomId, key, path, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        setAcl: (roomId, key, path, value, overrideBotUrl, overrideAccessToken) => stateBot.acl.v1beta1.setAcl(roomId, key, path, value, overrideBotUrl || botUrl, overrideAccessToken || accessToken)
+        queryAcl: (roomId, key, path, openIdToken, authDid, overrideBotUrl) => queryAcl(roomId, key, path, overrideBotUrl || botUrl, openIdToken, authDid),
+        setAcl: (roomId, key, path, value, openIdToken, authDid, overrideBotUrl) => setAcl(roomId, key, path, value, overrideBotUrl || botUrl, openIdToken, authDid)
       }
@@ -33,3 +19,5 @@ },
       v1beta1: {
-        invite: (roomId, overrideBotUrl, overrideAccessToken) => stateBot.bot.v1beta1.invite(roomId, overrideBotUrl || botUrl, overrideAccessToken || accessToken)
+        invite: roomId => invite(roomId, botUrl, homeServerUrl, accessToken),
+        invited: roomId => invited(roomId, botUrl),
+        getConfig: () => getConfig(botUrl)
       }
@@ -39,4 +27,4 @@ },
       v1beta1: {
-        queryState: (roomId, key, path, overrideBotUrl, overrideAccessToken) => stateBot.state.v1beta1.queryState(roomId, key, path, overrideBotUrl || botUrl, overrideAccessToken || accessToken),
-        setState: (roomId, key, path, value, overrideBotUrl, overrideAccessToken) => stateBot.state.v1beta1.setState(roomId, key, path, value, overrideBotUrl || botUrl, overrideAccessToken || accessToken)
+        queryState: (roomId, key, path, openIdToken, authDid, overrideBotUrl) => queryState(roomId, key, path, overrideBotUrl || botUrl, openIdToken, authDid),
+        setState: (roomId, key, path, value, openIdToken, authDid, overrideBotUrl) => setState(roomId, key, path, value, overrideBotUrl || botUrl, openIdToken, authDid)
       }
@@ -43,0 +31,0 @@ }

module/stateBot/state/v1beta1.js

 import fetch from 'node-fetch';
 import { throwResponseError } from '../../utils/error';
 import { isValidRoomId } from '../../utils/validators';
-export async function queryState(roomId, key, path, botUrl, accessToken) {
+import { cleanUrl } from '../../utils/url';
+import { botRestHeaders } from '../../utils/headers';
+export async function queryState(roomId, key, path, botUrl, openIdToken, authDid) {
   if (!isValidRoomId(roomId)) {
     throw new Error('Invalid room ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -19,6 +21,3 @@ action: 'get',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: accessToken ? `Bearer ${accessToken}` : undefined
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -32,7 +31,7 @@ });
 }
-export async function setState(roomId, key, path, value, botUrl, accessToken) {
+export async function setState(roomId, key, path, value, botUrl, openIdToken, authDid) {
   if (!isValidRoomId(roomId)) {
     throw new Error('Invalid room ID');
   }
-  const url = `${botUrl}/action`;
+  const url = cleanUrl(`${botUrl}/action`);
   const payload = {
@@ -49,6 +48,3 @@ action: 'set',
     method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: accessToken ? `Bearer ${accessToken}` : undefined
-    },
+    headers: botRestHeaders(openIdToken, authDid),
     body: JSON.stringify(payload)
@@ -55,0 +51,0 @@ });

module/utils/index.js

 import * as _1 from './mxc';
 import * as _2 from './validators';
+export { botRestHeaders } from './headers';
 export let utils;
@@ -4,0 +5,0 @@ (function (_utils) {

module/utils/url.js

 export function cleanUrl(url) {
-  // Remove line breakers such as \n and any other whitespace characters
-  let cleanUrl = url.replace(/[\n\r\s]/g, '');
-
-  // Regular expression to match duplicate slashes except for the first one after "https://" or "http://"
-  const regex = /(https?:\/\/|[^:])\/\//g;
-
-  // Replace duplicate slashes with a single slash, excluding the first one after "https://" or "http://"
-  cleanUrl = cleanUrl.replace(regex, (match, p1, offset, string) => {
-    // If match starts with http: or https:, keep it as it is.
-    if (p1 === 'http://' || p1 === 'https://') {
-      return match;
-    } else {
-      // Otherwise, replace the extra slashes with a single slash
-      return p1 + '/';
-    }
-  });
-  return cleanUrl;
+  return url.replace(/([^:]\/)\/+/g, '$1');
 }

package.json

 {
   "name": "@ixo/matrixclient-sdk",
-  "version": "0.3.4",
+  "version": "1.0.0",
   "description": "An SDK to easily interact with Matrix servers",
@@ -5,0 +5,0 @@ "author": "ixo",

README.md

@@ -25,2 +25,3 @@ # IXO MATRIX CLIENT SDK
   - [Getting Started](#getting-started)
+  - [Authentication](#authentication)
   - [Matrix API Client](#matrix-api-client)
@@ -48,2 +49,3 @@ - [Account](#account)
 
+
 ## Installation
@@ -80,2 +82,27 @@
 
+## Authentication
+
+The SDK uses two distinct authentication mechanisms depending on what is being called:
+
+### OpenID Tokens (Bot REST API)
+
+All bot REST API calls (claims, bids, state, ACLs, room sourcing) use **Matrix OpenID tokens** for authentication. OpenID tokens are short-lived (~1 hour) identity verification tokens that are validated by the bot via the Matrix federation endpoint. This is more secure than sending long-lived access tokens to external bot servers.
+
+Each bot method requires two authentication parameters passed per call:
+
+- `openIdToken`: A Matrix OpenID token obtained via the Matrix CS API (`/_matrix/client/v3/user/{userId}/openid/request_token`)
+- `authDid`: The caller's DID (e.g. `did:ixo:abc123`) — used by the bot to resolve the caller's homeserver and verify the token
+
+Because OpenID tokens are short-lived, they are **not** passed at client creation time. Instead, a fresh token must be provided on every method call.
+
+### Access Tokens (Matrix CS API)
+
+The `accessToken` parameter passed at client creation is a standard long-lived Matrix access token. It is only used for direct Matrix Client-Server (CS) API calls such as:
+
+- **`invite`**: Invites a bot to a room via the Matrix CS API (not sent to the bot server)
+- **`join`**: Joins a room via the Matrix CS API (room bot mixed methods)
+- **Matrix API client**: All profile, media, event, and room management calls
+
+This separation ensures that long-lived access tokens are never sent to external bot servers, following the security principle that sensitive credentials should only be sent to the user's own homeserver.
+
 ## Matrix API Client
@@ -233,10 +260,21 @@
   ```TS
-  const leaveResponse = await matrixApiClient.room.v1beta1.leave('!roomId:homeserver.url', 'leaving');
-  console.log(leaveResponse.room_id);
+  await matrixApiClient.room.v1beta1.leave('!roomId:homeserver.url', 'leaving');
   ```
 - `kick`: Kicks a user from a room if the user issuing the request has the necessary power level.
   ```TS
-  const kickResponse = await matrixApiClient.room.v1beta1.kick('!roomId:homeserver.url', '@user:homeserver.url', 'kicking');
-  console.log(kickResponse.room_id);
+  await matrixApiClient.room.v1beta1.kick('!roomId:homeserver.url', '@user:homeserver.url', 'kicking');
   ```
+- `inviteUser`: Invites a user to a room.
+  ```TS
+  await matrixApiClient.room.v1beta1.inviteUser('!roomId:homeserver.url', '@user:homeserver.url');
+  ```
+- `getPowerLevels`: Gets the power levels for a room.
+  ```TS
+  const powerLevels = await matrixApiClient.room.v1beta1.getPowerLevels('!roomId:homeserver.url');
+  console.log(powerLevels);
+  ```
+- `setPowerLevels`: Sets the power levels for a room.
+  ```TS
+  await matrixApiClient.room.v1beta1.setPowerLevels('!roomId:homeserver.url', content);
+  ```
 
@@ -251,3 +289,3 @@ ## Room Bot Client
   botUrl: 'https://your-bot-url',
-  accessToken: 'your-access-token'
+  accessToken: 'your-access-token' // optional, only needed for join operations
 });
@@ -258,23 +296,39 @@ ```
 
-Room Bot methods include managing entity rooms and invitations:
+Room Bot methods include managing entity rooms and invitations. All methods require `openIdToken` and `authDid` for bot authentication:
 
 - `sourceRoom`: Sources an entity room by its IID document (DID). If the room does not exist, it will be created. This method will also invite the user to the entity room if they have not been invited before.
   ```TS
-  const sourceRoomResponse = await matrixRoomBotClient.room.v1beta1.sourceRoom('did:ixo:entity:abc...xyz');
-  console.log(sourceRoomResponse.room_id);
+  const sourceRoomResponse = await matrixRoomBotClient.room.v1beta1.sourceRoom(
+    'did:ixo:entity:abc...xyz',
+    openIdToken,
+    authDid
+  );
+  console.log(sourceRoomResponse.roomId);
   ```
-- `sourceRoomAndJoin`: Similar to `sourceRoom` but also joins the entity room if the user is not already a member.
+- `sourceRoomAndJoin`: Similar to `sourceRoom` but also joins the entity room via the Matrix CS API.
   ```TS
-  const sourceRoomAndJoinResponse = await matrixRoomBotClient.room.v1beta1.sourceRoomAndJoin('did:ixo:entity:abc...xyz');
-  console.log(sourceRoomAndJoinResponse.room_id);
+  const response = await matrixRoomBotClient.room.v1beta1.sourceRoomAndJoin(
+    'did:ixo:entity:abc...xyz',
+    openIdToken,
+    authDid
+  );
+  console.log(response.roomId);
   ```
 - `roomInvite`: Invites the user to the entity room if the room exists, regardless of whether the user has been invited to the room before.
   ```TS
-  const roomInviteResponse = await matrixRoomBotClient.room.v1beta1.roomInvite('did:ixo:entity:abc...xyz');
-  console.log(roomInviteResponse.room_id);
+  const roomInviteResponse = await matrixRoomBotClient.room.v1beta1.roomInvite(
+    'did:ixo:entity:abc...xyz',
+    openIdToken,
+    authDid
+  );
+  console.log(roomInviteResponse.roomId);
   ```
-- `roomInviteAndJoin`: Similar to `roomInvite` but also joins the room if the user is not already a member.
+- `roomInviteAndJoin`: Similar to `roomInvite` but also joins the room via the Matrix CS API.
   ```TS
-  const roomInviteAndJoinResponse = await matrixRoomBotClient.room.v1beta1.roomInviteAndJoin('did:ixo:entity:abc...xyz');
-  console.log(roomInviteAndJoinResponse.room_id);
+  const response = await matrixRoomBotClient.room.v1beta1.roomInviteAndJoin(
+    'did:ixo:entity:abc...xyz',
+    openIdToken,
+    authDid
+  );
+  console.log(response.roomId);
   ```
@@ -289,3 +343,4 @@
   botUrl: 'https://your-bot-url',
-  accessToken: 'your-access-token' // optional
+  accessToken: 'your-access-token', // optional, only needed for invite
+  homeServerUrl: 'https://your-homeserver-url'
 });
@@ -303,3 +358,5 @@ ```
     'impactsX',
-    'profile'
+    'profile',
+    openIdToken,
+    authDid
   );
@@ -319,5 +376,7 @@ console.log(aclData.data);
       }
-    })
+    }),
+    openIdToken,
+    authDid
   );
-  console.log(setAclResponse.data);
+  console.log(setAclResponse.message);
   ```
@@ -327,10 +386,7 @@
 
-The bot methods provide functionality to interact with the state bot such as inviting it to a room to manage state and ACLs.
+The bot methods provide functionality to interact with the bots. These methods are shared across all bot clients (state, bid, claim).
 
-- `invite`: Invites the state bot to a specified room and adjusts its power level to ensure it has the necessary permissions to manage state events.
+- `invite`: Invites the bot to a specified room via the Matrix CS API and adjusts its power level to ensure it has the necessary permissions. This does not send your access token to the bot server.
   ```TS
-  const response = await matrixStateBotClient.bot.v1beta1.invite(
-    '!roomId:homeserver.url',
-  );
-  console.log(response);
+  await matrixStateBotClient.bot.v1beta1.invite('!roomId:homeserver.url');
   ```
@@ -340,2 +396,14 @@
 
+- `invited`: Checks if the bot is a member of a room.
+  ```TS
+  const response = await matrixStateBotClient.bot.v1beta1.invited('!roomId:homeserver.url');
+  console.log(response.isInvited);
+  ```
+
+- `getConfig`: Retrieves the bot's configuration including its user ID and homeserver details.
+  ```TS
+  const config = await matrixStateBotClient.bot.v1beta1.getConfig();
+  console.log(config.data.bot.userId);
+  ```
+
 ### State
@@ -350,3 +418,5 @@
     'impactsX',
-    'profile'
+    'profile',
+    openIdToken,
+    authDid
   );
@@ -364,5 +434,7 @@ console.log(stateData.data);
       avatar_url: 'mxc://matrix.org/abc123',
-    })
+    }),
+    openIdToken,
+    authDid
   );
-  console.log(setStateResponse.data);
+  console.log(setStateResponse.message);
   ```
@@ -379,3 +451,4 @@
   botUrl: 'https://your-bot-url',
-  accessToken: 'your-access-token'
+  accessToken: 'your-access-token', // optional, only needed for invite
+  homeServerUrl: 'https://your-homeserver-url'
 });
@@ -386,3 +459,3 @@ ```
 
-The bid methods allow you to manage bids within collections:
+The bid methods allow you to manage bids within collections. All methods require `openIdToken` and `authDid` for bot authentication:
 
@@ -394,2 +467,4 @@ - `queryBids`: Fetches all active bids for a collection with optional pagination.
     'collection', // claim collection id
+    openIdToken,
+    authDid,
     { nextPageToken: 'optional-token' }
@@ -405,3 +480,5 @@ );
     'collection', // claim collection id
-    'did:ixo:123'
+    'did:ixo:123',
+    openIdToken,
+    authDid
   );
@@ -416,4 +493,6 @@ console.log(bids.data); // Array of bids
     'collection', // claim collection id
-    '{"name":"John","surname":"Doe"}'
+    '{"name":"John","surname":"Doe"}',
     'SA',
+    openIdToken,
+    authDid
   );
@@ -429,3 +508,5 @@ console.log(response.id); // The new bid ID
     'collection', // claim collection id
-    'did:ixo:123'
+    'did:ixo:123',
+    openIdToken,
+    authDid
   );
@@ -442,3 +523,5 @@ console.log(response.id);
     'did:ixo:123',
-    'Rejection reason'
+    'Rejection reason',
+    openIdToken,
+    authDid
   );
@@ -453,3 +536,5 @@ console.log(response.id);
     'collection', // claim collection id
-    'did:ixo:123'
+    'did:ixo:123',
+    openIdToken,
+    authDid
   );
@@ -464,3 +549,5 @@ console.log(response.blocked); // true or false
     'collection', // claim collection id
-    'did:ixo:123'
+    'did:ixo:123',
+    openIdToken,
+    authDid
   );
@@ -474,3 +561,5 @@ console.log(response.blocked); // true
     'collection', // claim collection id
-    'did:ixo:123'
+    'did:ixo:123',
+    openIdToken,
+    authDid
   );
@@ -484,7 +573,6 @@ console.log(response.blocked); // false
 
-- `invite`: Invites the bid bot to a room.
+- `invite`: Invites the bid bot to a room via the Matrix CS API.
 
   ```TS
-  const response = await matrixBidBotClient.bot.v1beta1.invite('!roomId:homeserver.url');
-  console.log(response.message);
+  await matrixBidBotClient.bot.v1beta1.invite('!roomId:homeserver.url');
   ```
@@ -498,2 +586,8 @@
 
+- `getConfig`: Retrieves the bid bot's configuration.
+  ```TS
+  const config = await matrixBidBotClient.bot.v1beta1.getConfig();
+  console.log(config.data.bot.userId);
+  ```
+
 ## Claim Bot Client
@@ -506,3 +600,4 @@
   botUrl: 'https://your-bot-url',
-  accessToken: 'your-access-token' // optional
+  accessToken: 'your-access-token', // optional, only needed for invite
+  homeServerUrl: 'https://your-homeserver-url'
 });
@@ -513,3 +608,3 @@ ```
 
-The claim methods allow you to manage claims within collections:
+The claim methods allow you to manage claims within collections. All methods require `openIdToken` and `authDid` for bot authentication:
 
@@ -521,3 +616,5 @@ - `queryClaim`: Fetches a claim by its CID from a collection.
     'collection', // claim collection id
-    'claimCid'
+    'claimCid',
+    openIdToken,
+    authDid
   );
@@ -531,3 +628,5 @@ console.log(claim.data);
     'collection', // claim collection id
-    '{"name":"John","surname":"Doe"}'
+    '{"name":"John","surname":"Doe"}',
+    openIdToken,
+    authDid
   );
@@ -541,7 +640,6 @@ console.log(response.data.cid); // The CID of the saved claim
 
-- `invite`: Invites the claim bot to a room.
+- `invite`: Invites the claim bot to a room via the Matrix CS API.
 
   ```TS
-  const response = await matrixClaimBotClient.bot.v1beta1.invite('!roomId:homeserver.url');
-  console.log(response.message);
+  await matrixClaimBotClient.bot.v1beta1.invite('!roomId:homeserver.url');
   ```
@@ -555,2 +653,8 @@
 
+- `getConfig`: Retrieves the claim bot's configuration.
+  ```TS
+  const config = await matrixClaimBotClient.bot.v1beta1.getConfig();
+  console.log(config.data.bot.userId);
+  ```
+
 ## Utilities
@@ -557,0 +661,0 @@

types/api/account/v1beta1.d.ts

 export declare function queryWhoAmI(homeServerUrl: string, accessToken: string): Promise<string>;
+export declare function queryUsernameAvailable(username: string, homeServerUrl: string, accessToken: string): Promise<boolean>;

types/api/index.d.ts

@@ -27,2 +27,3 @@ import { UploadContentType } from './media/v1beta1';
             queryWhoAmI: (overrideHomeServerUrl?: string, overrideAccessToken?: string) => Promise<string>;
+            queryUsernameAvailable: (username: string, overrideHomeServerUrl?: string, overrideAccessToken?: string) => Promise<boolean>;
         };
@@ -41,2 +42,5 @@ };
             kick: (roomId: string, userId: string, reason: string, overrideHomeServerUrl?: string, overrideAccessToken?: string) => Promise<_3.KickResponse>;
+            inviteUser: (roomId: string, userId: string, overrideHomeServerUrl?: string, overrideAccessToken?: string) => Promise<_3.InviteUserResponse>;
+            getPowerLevels: (roomId: string, overrideHomeServerUrl?: string, overrideAccessToken?: string) => Promise<_3.PowerLevelsContent>;
+            setPowerLevels: (roomId: string, content: _3.PowerLevelsContent, overrideHomeServerUrl?: string, overrideAccessToken?: string) => Promise<_3.SetPowerLevelsResponse>;
         };
@@ -43,0 +47,0 @@ };

types/api/room/v1beta1.d.ts

@@ -31,2 +31,25 @@ export interface RoomDirectory {
 }
+export interface InviteUserResponse {
+}
+export interface PowerLevelsContent {
+    ban?: number;
+    events?: {
+        [eventType: string]: number;
+    };
+    events_default?: number;
+    invite?: number;
+    kick?: number;
+    notifications?: {
+        room?: number;
+    };
+    redact?: number;
+    state_default?: number;
+    users?: {
+        [userId: string]: number;
+    };
+    users_default?: number;
+    [key: string]: unknown;
+}
+export interface SetPowerLevelsResponse {
+}
 export declare function queryId(alias: string, homeServerUrl: string, accessToken?: string): Promise<RoomDirectory>;
@@ -41,1 +64,4 @@ export declare function queryVisibility(roomId: string, homeServerUrl?: string, accessToken?: string): Promise<RoomVisibility>;
 export declare function kick(roomId: string, userId: string, reason: string, homeServerUrl: string, accessToken: string): Promise<KickResponse>;
+export declare function inviteUser(roomId: string, userId: string, homeServerUrl: string, accessToken: string): Promise<InviteUserResponse>;
+export declare function getPowerLevels(roomId: string, homeServerUrl: string, accessToken: string): Promise<PowerLevelsContent>;
+export declare function setPowerLevels(roomId: string, content: PowerLevelsContent, homeServerUrl: string, accessToken: string): Promise<SetPowerLevelsResponse>;

types/bidBot/bid/v1beta1.d.ts

@@ -35,10 +35,10 @@ interface Bid {
     nextPageToken?: string;
-}, botUrl: string, accessToken: string): Promise<QueryBidsResponse>;
-export declare function queryBidsByDid(collection: string, did: string, botUrl: string, accessToken: string): Promise<QueryBidsResponse>;
-export declare function submitBid(collection: string, bid: string, role: string, botUrl: string, accessToken: string): Promise<SubmitBidResponse>;
-export declare function approveBid(bidId: string, collection: string, did: string, botUrl: string, accessToken: string): Promise<ApproveBidResponse>;
-export declare function rejectBid(bidId: string, collection: string, did: string, reason: string, botUrl: string, accessToken: string): Promise<RejectBidResponse>;
-export declare function queryDidIsBlocked(collection: string, did: string, botUrl: string, accessToken: string): Promise<QueryDidIsBlockedResponse>;
-export declare function didBlock(collection: string, did: string, botUrl: string, accessToken: string): Promise<DidBlockResponse>;
-export declare function didUnblock(collection: string, did: string, botUrl: string, accessToken: string): Promise<DidUnblockResponse>;
+}, botUrl: string, openIdToken: string, authDid: string): Promise<QueryBidsResponse>;
+export declare function queryBidsByDid(collection: string, did: string, botUrl: string, openIdToken: string, authDid: string): Promise<QueryBidsResponse>;
+export declare function submitBid(collection: string, bid: string, role: string, botUrl: string, openIdToken: string, authDid: string): Promise<SubmitBidResponse>;
+export declare function approveBid(bidId: string, collection: string, did: string, botUrl: string, openIdToken: string, authDid: string): Promise<ApproveBidResponse>;
+export declare function rejectBid(bidId: string, collection: string, did: string, reason: string, botUrl: string, openIdToken: string, authDid: string): Promise<RejectBidResponse>;
+export declare function queryDidIsBlocked(collection: string, did: string, botUrl: string, openIdToken: string, authDid: string): Promise<QueryDidIsBlockedResponse>;
+export declare function didBlock(collection: string, did: string, botUrl: string, openIdToken: string, authDid: string): Promise<DidBlockResponse>;
+export declare function didUnblock(collection: string, did: string, botUrl: string, openIdToken: string, authDid: string): Promise<DidUnblockResponse>;
 export {};

types/bidBot/bot/v1beta1.d.ts

@@ -1,8 +0,19 @@
-export interface InviteResponse {
-    message: string;
-}
 export interface InvitedResponse {
     isInvited: boolean;
 }
-export declare function invite(roomId: string, botUrl: string, accessToken: string): Promise<InviteResponse>;
+export interface BotConfigResponse {
+    data: {
+        bot: {
+            userId: string;
+            localpart: string;
+            displayName: string;
+            homeServerName?: string;
+        };
+        homeserverUrl: string;
+        autojoin: boolean;
+        encryption: boolean;
+    };
+}
+export declare function invite(roomId: string, botUrl: string, homeServerUrl: string, accessToken: string): Promise<void>;
 export declare function invited(roomId: string, botUrl: string): Promise<InvitedResponse>;
+export declare function getConfig(botUrl: string): Promise<BotConfigResponse>;

types/bidBot/index.d.ts

@@ -1,19 +0,18 @@
-import * as _1 from './bid/v1beta1';
-import * as _2 from './bot/v1beta1';
-export declare function createMatrixBidBotClient({ botUrl, accessToken }: {
+export declare function createMatrixBidBotClient({ botUrl, accessToken, homeServerUrl, }: {
     botUrl: string;
     accessToken?: string;
+    homeServerUrl: string;
 }): {
     bid: {
         v1beta1: {
-            queryBids: (collection: string, pagination?: {
+            queryBids: (collection: string, openIdToken: string, authDid: string, pagination?: {
                 nextPageToken?: string;
-            }, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.QueryBidsResponse>;
-            queryBidsByDid: (collection: string, did: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.QueryBidsResponse>;
-            submitBid: (collection: string, did: string, role: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.SubmitBidResponse>;
-            approveBid: (bidId: string, collection: string, did: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.ApproveBidResponse>;
-            rejectBid: (bidId: string, collection: string, did: string, reason: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.RejectBidResponse>;
-            queryDidIsBlocked: (collection: string, did: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.QueryDidIsBlockedResponse>;
-            didBlock: (collection: string, did: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.DidBlockResponse>;
-            didUnblock: (collection: string, did: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.DidUnblockResponse>;
+            }, overrideBotUrl?: string) => Promise<import("./bid/v1beta1").QueryBidsResponse>;
+            queryBidsByDid: (collection: string, did: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./bid/v1beta1").QueryBidsResponse>;
+            submitBid: (collection: string, bid: string, role: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./bid/v1beta1").SubmitBidResponse>;
+            approveBid: (bidId: string, collection: string, did: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./bid/v1beta1").ApproveBidResponse>;
+            rejectBid: (bidId: string, collection: string, did: string, reason: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./bid/v1beta1").RejectBidResponse>;
+            queryDidIsBlocked: (collection: string, did: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./bid/v1beta1").QueryDidIsBlockedResponse>;
+            didBlock: (collection: string, did: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./bid/v1beta1").DidBlockResponse>;
+            didUnblock: (collection: string, did: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./bid/v1beta1").DidUnblockResponse>;
         };
@@ -23,6 +22,7 @@ };
         v1beta1: {
-            invite: (roomId: string) => Promise<_2.InviteResponse>;
-            invited: (roomId: string) => Promise<_2.InvitedResponse>;
+            invite: (roomId: string) => Promise<void>;
+            invited: (roomId: string) => Promise<import("../bot/v1beta1").InvitedResponse>;
+            getConfig: () => Promise<import("../bot/v1beta1").BotConfigResponse>;
         };
     };
 };

types/claimBot/bot/v1beta1.d.ts

@@ -1,8 +0,19 @@
-export interface InviteResponse {
-    message: string;
-}
 export interface InvitedResponse {
     isInvited: boolean;
 }
-export declare function invite(roomId: string, botUrl: string, accessToken: string): Promise<InviteResponse>;
+export interface BotConfigResponse {
+    data: {
+        bot: {
+            userId: string;
+            localpart: string;
+            displayName: string;
+            homeServerName?: string;
+        };
+        homeserverUrl: string;
+        autojoin: boolean;
+        encryption: boolean;
+    };
+}
+export declare function invite(roomId: string, botUrl: string, homeServerUrl: string, accessToken: string): Promise<void>;
 export declare function invited(roomId: string, botUrl: string): Promise<InvitedResponse>;
+export declare function getConfig(botUrl: string): Promise<BotConfigResponse>;

types/claimBot/claim/v1beta1.d.ts

@@ -9,3 +9,3 @@ export interface QueryClaimResponse {
 }
-export declare function queryClaim(collection: string, cid: string, botUrl: string, accessToken: string): Promise<QueryClaimResponse>;
-export declare function saveClaim(collection: string, claim: string, botUrl: string, accessToken: string): Promise<SaveClaimResponse>;
+export declare function queryClaim(collection: string, cid: string, botUrl: string, openIdToken: string, authDid: string): Promise<QueryClaimResponse>;
+export declare function saveClaim(collection: string, claim: string, botUrl: string, openIdToken: string, authDid: string): Promise<SaveClaimResponse>;

types/claimBot/index.d.ts

@@ -1,11 +0,10 @@
-import * as _1 from './claim/v1beta1';
-import * as _2 from './bot/v1beta1';
-export declare function createMatrixClaimBotClient({ botUrl, accessToken }: {
+export declare function createMatrixClaimBotClient({ botUrl, accessToken, homeServerUrl, }: {
     botUrl: string;
     accessToken?: string;
+    homeServerUrl: string;
 }): {
     claim: {
         v1beta1: {
-            queryClaim: (collection: string, cid: string) => Promise<_1.QueryClaimResponse>;
-            saveClaim: (collection: string, claim: string) => Promise<_1.SaveClaimResponse>;
+            queryClaim: (collection: string, cid: string, openIdToken: string, authDid: string) => Promise<import("./claim/v1beta1").QueryClaimResponse>;
+            saveClaim: (collection: string, claim: string, openIdToken: string, authDid: string) => Promise<import("./claim/v1beta1").SaveClaimResponse>;
         };
@@ -15,6 +14,7 @@ };
         v1beta1: {
-            invite: (roomId: string) => Promise<_2.InviteResponse>;
-            invited: (roomId: string) => Promise<_2.InvitedResponse>;
+            invite: (roomId: string) => Promise<void>;
+            invited: (roomId: string) => Promise<import("../bot/v1beta1").InvitedResponse>;
+            getConfig: () => Promise<import("../bot/v1beta1").BotConfigResponse>;
         };
     };
 };

types/roomBot/index.d.ts

@@ -5,12 +5,12 @@ import * as _1 from './room/v1beta1';
     botUrl: string;
-    accessToken: string;
+    accessToken?: string;
 }): {
     room: {
         v1beta1: {
-            sourceRoom: (did: string, overrideBotUrl?: string, overrideAccessToken?: string, groupUsers?: _1.GroupUsers) => Promise<_1.SourceRoomResponse>;
-            sourceRoomAndJoin: (did: string, overrideHomeServerUrl?: string, overrideBotUrl?: string, overrideAccessToken?: string, groupUsers?: _1.GroupUsers) => Promise<_1.SourceRoomResponse>;
-            roomInvite: (did: string, overrideBotUrl?: string, overrideAccessToken?: string, groupUsers?: _1.GroupUsers) => Promise<_1.SourceRoomResponse>;
-            roomInviteAndJoin: (did: string, overrideHomeServerUrl?: string, overrideBotUrl?: string, overrideAccessToken?: string, groupUsers?: _1.GroupUsers) => Promise<_1.SourceRoomResponse>;
+            sourceRoom: (did: string, openIdToken: string, authDid: string, overrideBotUrl?: string, groupUsers?: _1.GroupUsers) => Promise<_1.SourceRoomResponse>;
+            sourceRoomAndJoin: (did: string, openIdToken: string, authDid: string, overrideHomeServerUrl?: string, overrideBotUrl?: string, overrideAccessToken?: string, groupUsers?: _1.GroupUsers) => Promise<_1.SourceRoomResponse>;
+            roomInvite: (did: string, openIdToken: string, authDid: string, overrideBotUrl?: string, groupUsers?: _1.GroupUsers) => Promise<_1.SourceRoomResponse>;
+            roomInviteAndJoin: (did: string, openIdToken: string, authDid: string, overrideHomeServerUrl?: string, overrideBotUrl?: string, overrideAccessToken?: string, groupUsers?: _1.GroupUsers) => Promise<_1.SourceRoomResponse>;
         };
     };
 };

types/roomBot/room/v1beta1.d.ts

@@ -11,5 +11,5 @@ export type GroupUsers = {
 }
-export declare function sourceRoom(did: string, botUrl: string, accessToken?: string, groupUsers?: GroupUsers): Promise<SourceRoomResponse>;
-export declare function sourceRoomAndJoin(did: string, homeServerUrl: string, botUrl: string, accessToken: string, groupUsers?: GroupUsers): Promise<SourceRoomResponse>;
-export declare function roomInvite(did: string, botUrl: string, accessToken: string, groupUsers?: GroupUsers): Promise<SourceRoomResponse>;
-export declare function roomInviteAndJoin(did: string, homeServerUrl: string, botUrl: string, accessToken: string, groupUsers?: GroupUsers): Promise<SourceRoomResponse>;
+export declare function sourceRoom(did: string, botUrl: string, openIdToken: string, authDid: string, groupUsers?: GroupUsers): Promise<SourceRoomResponse>;
+export declare function sourceRoomAndJoin(did: string, homeServerUrl: string, botUrl: string, openIdToken: string, authDid: string, accessToken: string, groupUsers?: GroupUsers): Promise<SourceRoomResponse>;
+export declare function roomInvite(did: string, botUrl: string, openIdToken: string, authDid: string, groupUsers?: GroupUsers): Promise<SourceRoomResponse>;
+export declare function roomInviteAndJoin(did: string, homeServerUrl: string, botUrl: string, openIdToken: string, authDid: string, accessToken: string, groupUsers?: GroupUsers): Promise<SourceRoomResponse>;

types/stateBot/acl/v1beta1.d.ts

@@ -13,3 +13,3 @@ export interface AclData {
 }
-export declare function queryAcl<T = AclData>(roomId: string, key: string, path: string, botUrl: string, accessToken?: string): Promise<QueryAclResponse<T>>;
-export declare function setAcl(roomId: string, key: string, path: string, value: string, botUrl: string, accessToken?: string): Promise<SetAclResponse>;
+export declare function queryAcl<T = AclData>(roomId: string, key: string, path: string, botUrl: string, openIdToken: string, authDid: string): Promise<QueryAclResponse<T>>;
+export declare function setAcl(roomId: string, key: string, path: string, value: string, botUrl: string, openIdToken: string, authDid: string): Promise<SetAclResponse>;

types/stateBot/bot/v1beta1.d.ts

@@ -1,4 +0,15 @@
-export interface InviteResponse {
-    message: string;
+export interface BotConfigResponse {
+    data: {
+        bot: {
+            userId: string;
+            localpart: string;
+            displayName: string;
+            homeServerName?: string;
+        };
+        homeserverUrl: string;
+        autojoin: boolean;
+        encryption: boolean;
+    };
 }
-export declare function invite(roomId: string, botUrl: string, accessToken: string): Promise<InviteResponse>;
+export declare function invite(roomId: string, botUrl: string, homeServerUrl: string, accessToken: string): Promise<void>;
+export declare function getConfig(botUrl: string): Promise<BotConfigResponse>;

types/stateBot/index.d.ts

@@ -1,12 +0,10 @@
-import * as _1 from './acl/v1beta1';
-import * as _2 from './bot/v1beta1';
-import * as _3 from './state/v1beta1';
-export declare function createMatrixStateBotClient({ botUrl, accessToken }: {
+export declare function createMatrixStateBotClient({ botUrl, accessToken, homeServerUrl, }: {
     botUrl: string;
     accessToken?: string;
+    homeServerUrl: string;
 }): {
     acl: {
         v1beta1: {
-            queryAcl: (roomId: string, key?: string, path?: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.QueryAclResponse<_1.AclData>>;
-            setAcl: (roomId: string, key: string, path: string, value: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_1.SetAclResponse>;
+            queryAcl: (roomId: string, key: string, path: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./acl/v1beta1").QueryAclResponse<import("./acl/v1beta1").AclData>>;
+            setAcl: (roomId: string, key: string, path: string, value: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./acl/v1beta1").SetAclResponse>;
         };
@@ -16,3 +14,5 @@ };
         v1beta1: {
-            invite: (roomId: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_2.InviteResponse>;
+            invite: (roomId: string) => Promise<void>;
+            invited: (roomId: string) => Promise<import("../bot/v1beta1").InvitedResponse>;
+            getConfig: () => Promise<import("../bot/v1beta1").BotConfigResponse>;
         };
@@ -22,6 +22,6 @@ };
         v1beta1: {
-            queryState: (roomId: string, key?: string, path?: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_3.QueryStateResponse<unknown>>;
-            setState: (roomId: string, key: string, path: string, value: string, overrideBotUrl?: string, overrideAccessToken?: string) => Promise<_3.SetStateResponse>;
+            queryState: (roomId: string, key: string, path: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./state/v1beta1").QueryStateResponse<unknown>>;
+            setState: (roomId: string, key: string, path: string, value: string, openIdToken: string, authDid: string, overrideBotUrl?: string) => Promise<import("./state/v1beta1").SetStateResponse>;
         };
     };
 };

types/stateBot/state/v1beta1.d.ts

@@ -7,3 +7,3 @@ export interface QueryStateResponse<T = unknown> {
 }
-export declare function queryState<T = unknown>(roomId: string, key: string, path: string, botUrl: string, accessToken?: string): Promise<QueryStateResponse<T>>;
-export declare function setState(roomId: string, key: string, path: string, value: string, botUrl: string, accessToken?: string): Promise<SetStateResponse>;
+export declare function queryState<T = unknown>(roomId: string, key: string, path: string, botUrl: string, openIdToken: string, authDid: string): Promise<QueryStateResponse<T>>;
+export declare function setState(roomId: string, key: string, path: string, value: string, botUrl: string, openIdToken: string, authDid: string): Promise<SetStateResponse>;

types/utils/index.d.ts

 import * as _1 from './mxc';
 import * as _2 from './validators';
+export { botRestHeaders } from './headers';
 export declare namespace utils {
@@ -4,0 +5,0 @@ const mxc: typeof _1;

main/bidBot/bot/v1beta1.js

-"use strict";
-
-var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-Object.defineProperty(exports, "__esModule", {
-  value: true
-});
-exports.invite = invite;
-exports.invited = invited;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
-var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
-var _nodeFetch = _interopRequireDefault(require("node-fetch"));
-var _error = require("../../utils/error");
-var _validators = require("../../utils/validators");
-function invite(_x, _x2, _x3) {
-  return _invite.apply(this, arguments);
-}
-function _invite() {
-  _invite = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(roomId, botUrl, accessToken) {
-    var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
-        case 0:
-          if ((0, _validators.isValidRoomId)(roomId)) {
-            _context.next = 2;
-            break;
-          }
-          throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/invite");
-          payload = {
-            roomId: roomId
-          };
-          _context.next = 6;
-          return (0, _nodeFetch["default"])(url, {
-            method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: accessToken ? "Bearer ".concat(accessToken) : undefined
-            },
-            body: JSON.stringify(payload)
-          });
-        case 6:
-          response = _context.sent;
-          if (response.ok) {
-            _context.next = 10;
-            break;
-          }
-          _context.next = 10;
-          return (0, _error.throwResponseError)(response);
-        case 10:
-          _context.next = 12;
-          return response.json();
-        case 12:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context.stop();
-      }
-    }, _callee);
-  }));
-  return _invite.apply(this, arguments);
-}
-function invited(_x4, _x5) {
-  return _invited.apply(this, arguments);
-}
-function _invited() {
-  _invited = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(roomId, botUrl) {
-    var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
-        case 0:
-          if ((0, _validators.isValidRoomId)(roomId)) {
-            _context2.next = 2;
-            break;
-          }
-          throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/invited");
-          payload = {
-            roomId: roomId
-          };
-          _context2.next = 6;
-          return (0, _nodeFetch["default"])(url, {
-            method: 'POST',
-            headers: {
-              'Content-Type': 'application/json'
-            },
-            body: JSON.stringify(payload)
-          });
-        case 6:
-          response = _context2.sent;
-          if (response.ok) {
-            _context2.next = 10;
-            break;
-          }
-          _context2.next = 10;
-          return (0, _error.throwResponseError)(response);
-        case 10:
-          _context2.next = 12;
-          return response.json();
-        case 12:
-          data = _context2.sent;
-          return _context2.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context2.stop();
-      }
-    }, _callee2);
-  }));
-  return _invited.apply(this, arguments);
-}

main/claimBot/bot/v1beta1.js

-"use strict";
-
-var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-Object.defineProperty(exports, "__esModule", {
-  value: true
-});
-exports.invite = invite;
-exports.invited = invited;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
-var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
-var _nodeFetch = _interopRequireDefault(require("node-fetch"));
-var _error = require("../../utils/error");
-var _validators = require("../../utils/validators");
-function invite(_x, _x2, _x3) {
-  return _invite.apply(this, arguments);
-}
-function _invite() {
-  _invite = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(roomId, botUrl, accessToken) {
-    var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
-        case 0:
-          if ((0, _validators.isValidRoomId)(roomId)) {
-            _context.next = 2;
-            break;
-          }
-          throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/invite");
-          payload = {
-            roomId: roomId
-          };
-          _context.next = 6;
-          return (0, _nodeFetch["default"])(url, {
-            method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: accessToken ? "Bearer ".concat(accessToken) : undefined
-            },
-            body: JSON.stringify(payload)
-          });
-        case 6:
-          response = _context.sent;
-          if (response.ok) {
-            _context.next = 10;
-            break;
-          }
-          _context.next = 10;
-          return (0, _error.throwResponseError)(response);
-        case 10:
-          _context.next = 12;
-          return response.json();
-        case 12:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context.stop();
-      }
-    }, _callee);
-  }));
-  return _invite.apply(this, arguments);
-}
-function invited(_x4, _x5) {
-  return _invited.apply(this, arguments);
-}
-function _invited() {
-  _invited = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(roomId, botUrl) {
-    var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee2$(_context2) {
-      while (1) switch (_context2.prev = _context2.next) {
-        case 0:
-          if ((0, _validators.isValidRoomId)(roomId)) {
-            _context2.next = 2;
-            break;
-          }
-          throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/invited");
-          payload = {
-            roomId: roomId
-          };
-          _context2.next = 6;
-          return (0, _nodeFetch["default"])(url, {
-            method: 'POST',
-            headers: {
-              'Content-Type': 'application/json'
-            },
-            body: JSON.stringify(payload)
-          });
-        case 6:
-          response = _context2.sent;
-          if (response.ok) {
-            _context2.next = 10;
-            break;
-          }
-          _context2.next = 10;
-          return (0, _error.throwResponseError)(response);
-        case 10:
-          _context2.next = 12;
-          return response.json();
-        case 12:
-          data = _context2.sent;
-          return _context2.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context2.stop();
-      }
-    }, _callee2);
-  }));
-  return _invited.apply(this, arguments);
-}

main/stateBot/bot/v1beta1.js

-"use strict";
-
-var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
-Object.defineProperty(exports, "__esModule", {
-  value: true
-});
-exports.invite = invite;
-var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
-var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
-var _nodeFetch = _interopRequireDefault(require("node-fetch"));
-var _error = require("../../utils/error");
-var _validators = require("../../utils/validators");
-function invite(_x, _x2, _x3) {
-  return _invite.apply(this, arguments);
-}
-function _invite() {
-  _invite = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(roomId, botUrl, accessToken) {
-    var url, payload, response, data;
-    return _regenerator["default"].wrap(function _callee$(_context) {
-      while (1) switch (_context.prev = _context.next) {
-        case 0:
-          if ((0, _validators.isValidRoomId)(roomId)) {
-            _context.next = 2;
-            break;
-          }
-          throw new Error('Invalid room ID');
-        case 2:
-          url = "".concat(botUrl, "/invite");
-          payload = {
-            roomId: roomId
-          };
-          _context.next = 6;
-          return (0, _nodeFetch["default"])(url, {
-            method: 'POST',
-            headers: {
-              'Content-Type': 'application/json',
-              Authorization: accessToken ? "Bearer ".concat(accessToken) : undefined
-            },
-            body: JSON.stringify(payload)
-          });
-        case 6:
-          response = _context.sent;
-          if (response.ok) {
-            _context.next = 10;
-            break;
-          }
-          _context.next = 10;
-          return (0, _error.throwResponseError)(response);
-        case 10:
-          _context.next = 12;
-          return response.json();
-        case 12:
-          data = _context.sent;
-          return _context.abrupt("return", data);
-        case 14:
-        case "end":
-          return _context.stop();
-      }
-    }, _callee);
-  }));
-  return _invite.apply(this, arguments);
-}

module/bidBot/bot/v1beta1.js

-import fetch from 'node-fetch';
-import { throwResponseError } from '../../utils/error';
-import { isValidRoomId } from '../../utils/validators';
-export async function invite(roomId, botUrl, accessToken) {
-  if (!isValidRoomId(roomId)) {
-    throw new Error('Invalid room ID');
-  }
-  const url = `${botUrl}/invite`;
-  const payload = {
-    roomId: roomId
-  };
-  const response = await fetch(url, {
-    method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: accessToken ? `Bearer ${accessToken}` : undefined
-    },
-    body: JSON.stringify(payload)
-  });
-  if (!response.ok) {
-    await throwResponseError(response);
-  }
-  const data = await response.json();
-  return data;
-}
-export async function invited(roomId, botUrl) {
-  if (!isValidRoomId(roomId)) {
-    throw new Error('Invalid room ID');
-  }
-  const url = `${botUrl}/invited`;
-  const payload = {
-    roomId: roomId
-  };
-  const response = await fetch(url, {
-    method: 'POST',
-    headers: {
-      'Content-Type': 'application/json'
-    },
-    body: JSON.stringify(payload)
-  });
-  if (!response.ok) {
-    await throwResponseError(response);
-  }
-  const data = await response.json();
-  return data;
-}

module/claimBot/bot/v1beta1.js

-import fetch from 'node-fetch';
-import { throwResponseError } from '../../utils/error';
-import { isValidRoomId } from '../../utils/validators';
-export async function invite(roomId, botUrl, accessToken) {
-  if (!isValidRoomId(roomId)) {
-    throw new Error('Invalid room ID');
-  }
-  const url = `${botUrl}/invite`;
-  const payload = {
-    roomId: roomId
-  };
-  const response = await fetch(url, {
-    method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: accessToken ? `Bearer ${accessToken}` : undefined
-    },
-    body: JSON.stringify(payload)
-  });
-  if (!response.ok) {
-    await throwResponseError(response);
-  }
-  const data = await response.json();
-  return data;
-}
-export async function invited(roomId, botUrl) {
-  if (!isValidRoomId(roomId)) {
-    throw new Error('Invalid room ID');
-  }
-  const url = `${botUrl}/invited`;
-  const payload = {
-    roomId: roomId
-  };
-  const response = await fetch(url, {
-    method: 'POST',
-    headers: {
-      'Content-Type': 'application/json'
-    },
-    body: JSON.stringify(payload)
-  });
-  if (!response.ok) {
-    await throwResponseError(response);
-  }
-  const data = await response.json();
-  return data;
-}

module/stateBot/bot/v1beta1.js

-import fetch from 'node-fetch';
-import { throwResponseError } from '../../utils/error';
-import { isValidRoomId } from '../../utils/validators';
-export async function invite(roomId, botUrl, accessToken) {
-  if (!isValidRoomId(roomId)) {
-    throw new Error('Invalid room ID');
-  }
-  const url = `${botUrl}/invite`;
-  const payload = {
-    roomId: roomId
-  };
-  const response = await fetch(url, {
-    method: 'POST',
-    headers: {
-      'Content-Type': 'application/json',
-      Authorization: accessToken ? `Bearer ${accessToken}` : undefined
-    },
-    body: JSON.stringify(payload)
-  });
-  if (!response.ok) {
-    await throwResponseError(response);
-  }
-  const data = await response.json();
-  return data;
-}

Fixed alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

284638

19.67%

Lines of code

5486

2.14%

Number of low quality alerts

1

-50%

Number of lines in readme file

708

17.22%

Number of medium supply chain risk alerts

53

-1.85%

No dependency changes