Release 1.54.1

Author: CodesphereBot

main.js

@@ -43668,12 +43668,25 @@ var require_json = __commonJS({
   }
 });
 
+// packages/utils/common/lib/runTimes.js
+var require_runTimes = __commonJS({
+  "packages/utils/common/lib/runTimes.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.runTimes = void 0;
+    var runTimes = (n, fn) => {
+      return [...Array(n).keys()].map(fn);
+    };
+    exports2.runTimes = runTimes;
+  }
+});
+
 // packages/streamy/common/lib/support/array.js
 var require_array2 = __commonJS({
   "packages/streamy/common/lib/support/array.js"(exports2) {
     "use strict";
     Object.defineProperty(exports2, "__esModule", { value: true });
-    exports2.repeatCallInOrder = exports2.repeat = exports2.mapAsync = exports2.mapInOrder = exports2.forEachInOrder = exports2.forEachAsync = exports2.forCountInOrder = exports2.forCount = exports2.createArray = void 0;
+    exports2.runTimes = exports2.repeatCallInOrder = exports2.repeat = exports2.mapAsync = exports2.mapInOrder = exports2.forEachInOrder = exports2.forEachAsync = exports2.forCountInOrder = exports2.forCount = exports2.createArray = void 0;
     var array_1 = require_array();
     Object.defineProperty(exports2, "createArray", { enumerable: true, get: function() {
       return array_1.createArray;
@@ -43702,6 +43715,10 @@ var require_array2 = __commonJS({
     Object.defineProperty(exports2, "repeatCallInOrder", { enumerable: true, get: function() {
       return array_1.repeatCallInOrder;
     } });
+    var runTimes_1 = require_runTimes();
+    Object.defineProperty(exports2, "runTimes", { enumerable: true, get: function() {
+      return runTimes_1.runTimes;
+    } });
   }
 });
 
@@ -47310,6 +47327,7 @@ var require_experiments = __commonJS({
     exports2.MAINTENANCE_MODE_EXP_NAME = "maintenance-mode";
     var AVAILABLE_EXPERIMENTS = [
       "ceph-subtree-pinning",
+      "ci-profile",
       "env-state",
       "esbuild",
       "external-mounter",
@@ -52418,7 +52436,7 @@ var require_Workspace = __commonJS({
   "packages/workspace-service/common/lib/Workspace.js"(exports2) {
     "use strict";
     Object.defineProperty(exports2, "__esModule", { value: true });
-    exports2.mapToServerV2 = exports2.mapToServerV1 = exports2.isServerV2 = exports2.devDomainToWsId = exports2.workspaceDevDomain = exports2.DEFAULT_WORKSPACE_PORTS = exports2.DEFAULT_PORT = exports2.IDE_SERVER_NAME = exports2.uniqueServerId = exports2.toServer = exports2.toServerV1 = exports2.serverV1 = exports2.toServerV2 = exports2.serverV2 = exports2.toMsdServerName = exports2.validServerNameRegex = exports2.toWorkspace = exports2.workspace = exports2.SUPPORTED_GIT_PROVIDERS = exports2.toGitProvider = exports2.GitProvider = void 0;
+    exports2.mapToServerV2 = exports2.mapToServerV1 = exports2.mapToServerV1Fallback = exports2.isServerV2 = exports2.devDomainToWsId = exports2.workspaceDevDomain = exports2.DEFAULT_WORKSPACE_PORTS = exports2.DEFAULT_PORT = exports2.IDE_SERVER_NAME = exports2.uniqueServerId = exports2.toServer = exports2.toServerV1 = exports2.serverV1 = exports2.toServerV2 = exports2.serverV2 = exports2.toMsdServerName = exports2.validServerNameRegex = exports2.toWorkspace = exports2.workspace = exports2.SUPPORTED_GIT_PROVIDERS = exports2.toGitProvider = exports2.GitProvider = void 0;
     var Plan_1 = require_Plan();
     var errors_1 = require_errors();
     var preconditions_1 = require_preconditions();
@@ -52506,6 +52524,18 @@ var require_Workspace = __commonJS({
     exports2.devDomainToWsId = devDomainToWsId;
     var isServerV2 = (server) => (0, typing_1.isOfType)(server, exports2.toServerV2);
     exports2.isServerV2 = isServerV2;
+    var mapToServerV1Fallback = (server) => {
+      if (!(0, exports2.isServerV2)(server)) {
+        return server;
+      }
+      return server.network.ports.some((p) => exports2.DEFAULT_PORT === p.port) ? (0, exports2.mapToServerV1)(server) : {
+        ...server,
+        isPublic: true,
+        stripPath: false,
+        network: void 0
+      };
+    };
+    exports2.mapToServerV1Fallback = mapToServerV1Fallback;
     var mapToServerV1 = (server) => {
       var _a;
       if (!(0, exports2.isServerV2)(server)) {
@@ -52678,7 +52708,7 @@ var require_pipeline = __commonJS({
       return c > 3 && r && Object.defineProperty(target, key, r), r;
     };
     Object.defineProperty(exports2, "__esModule", { value: true });
-    exports2.PipelineStub = exports2.pipelineService = exports2.isStageExecConfigV1 = exports2.toStageExecConfig = exports2.toStageConfig = void 0;
+    exports2.PipelineStub = exports2.pipelineService = exports2.isStageExecConfigV1 = exports2.toStageExecConfig = exports2.toStageConfig = exports2.DEFAULT_CI_PROFILE = void 0;
     var inversify_1 = require_inversify();
     var spec_1 = require_spec2();
     var typing_1 = require_typing3();
@@ -52688,6 +52718,7 @@ var require_pipeline = __commonJS({
     var config_1 = require_config2();
     var logging_12 = require_logging3();
     var types_1 = require_types5();
+    exports2.DEFAULT_CI_PROFILE = "ci_default";
     var toSetConfigArgs = (0, typing_2.toObject)({
       config: (0, typing_2.toNullOr)(types_1.toPipelineConfig),
       profile: (0, typing_2.toUndefOr)(typing_2.toString)
@@ -52728,7 +52759,7 @@ var require_pipeline = __commonJS({
         configStream: (0, spec_2.stream)({
           access: "internal",
           response: (0, typing_2.toNullOr)(types_1.toPipelineConfig),
-          request: typing_2.toUndef
+          request: (0, typing_2.toUndefOr)(typing_2.toString)
         }),
         setConfig: (0, spec_2.rpc)({
           access: "internal",
@@ -52782,6 +52813,11 @@ var require_pipeline = __commonJS({
           request: (0, typing_2.toObject)({
             stage: (0, typing_2.toLiteralUnion)("stage", types_1.stageKinds)
           })
+        }),
+        pipelineProfiles: (0, spec_2.stream)({
+          access: "internal",
+          response: (0, typing_2.toArray)(typing_2.toString),
+          request: typing_2.toUndef
         })
       }
     };
@@ -138527,6 +138563,15 @@ var require_database = __commonJS({
         return `${this.column.toSql()} is NULL`;
       }
     };
+    var SqlIsNotNull = class extends SqlPart {
+      constructor(column) {
+        super();
+        this.column = column;
+      }
+      toSql() {
+        return `${this.column.toSql()} IS NOT NULL`;
+      }
+    };
     var SqlCompositeCondition = class extends SqlPartWithValue {
       constructor(conditions) {
         super();
@@ -138541,12 +138586,12 @@ var require_database = __commonJS({
     };
     var SqlAnd = class extends SqlCompositeCondition {
       toSql(dialect) {
-        return this.conditions.map((x) => x.toSql(dialect)).join(" AND ");
+        return `(${this.conditions.map((x) => x.toSql(dialect)).join(" AND ")})`;
       }
     };
     var SqlOr = class extends SqlCompositeCondition {
       toSql(dialect) {
-        return this.conditions.map((x) => x.toSql(dialect)).join(" OR ");
+        return `(${this.conditions.map((x) => x.toSql(dialect)).join(" OR ")})`;
       }
     };
     var toEqualsComparison = (0, typing_1.toObject)({ "==": typing_1.toAny }, { strict: true });
@@ -138566,7 +138611,7 @@ var require_database = __commonJS({
     var isOrCondition = (c) => (0, typing_1.isOfType)(c, (0, typing_1.toObject)({ or: (0, typing_1.toArray)(toComparison) }));
     exports2.isOrCondition = isOrCondition;
     var comparisonToSql = (col, toSqlValue, comparison) => {
-      return comparison === void 0 ? new SqlIsNull(col) : (0, typing_1.isOfType)(comparison, toEqualsComparison) ? new SqlEquals(col, toSqlValue(comparison["=="])) : (0, typing_1.isOfType)(comparison, toGreaterThanComparison) ? new SqlGreaterThan(col, toSqlValue(comparison[">"])) : (0, typing_1.isOfType)(comparison, toGreaterThanEqualsComparison) ? new SqlGreaterThanEquals(col, toSqlValue(comparison[">="])) : (0, typing_1.isOfType)(comparison, toLessThanComparison) ? new SqlLessThan(col, toSqlValue(comparison["<"])) : (0, typing_1.isOfType)(comparison, toLessThanEqualsComparison) ? new SqlLessThanEquals(col, toSqlValue(comparison["<="])) : (0, typing_1.isOfType)(comparison, toNotEqualsComparison) ? new SqlNotEquals(col, toSqlValue(comparison["!="])) : (0, typing_1.isOfType)(comparison, toBetweenComparison) ? new SqlBetween(col, toSqlValue(comparison.between.lower), toSqlValue(comparison.between.upper)) : (0, typing_1.isOfType)(comparison, toLikeComparison) ? new SqlLike(col, toSqlValue(comparison.like)) : (0, typing_1.isOfType)(comparison, toInComparison) ? new SqlIn(col, comparison.in.map(toSqlValue)) : new SqlEquals(col, toSqlValue(comparison));
+      return comparison === void 0 ? new SqlIsNull(col) : (0, typing_1.isOfType)(comparison, toEqualsComparison) ? comparison["=="] === void 0 ? new SqlIsNull(col) : new SqlEquals(col, toSqlValue(comparison["=="])) : (0, typing_1.isOfType)(comparison, toGreaterThanComparison) ? new SqlGreaterThan(col, toSqlValue(comparison[">"])) : (0, typing_1.isOfType)(comparison, toGreaterThanEqualsComparison) ? new SqlGreaterThanEquals(col, toSqlValue(comparison[">="])) : (0, typing_1.isOfType)(comparison, toLessThanComparison) ? new SqlLessThan(col, toSqlValue(comparison["<"])) : (0, typing_1.isOfType)(comparison, toLessThanEqualsComparison) ? new SqlLessThanEquals(col, toSqlValue(comparison["<="])) : (0, typing_1.isOfType)(comparison, toNotEqualsComparison) ? comparison["!="] === void 0 ? new SqlIsNotNull(col) : new SqlNotEquals(col, toSqlValue(comparison["!="])) : (0, typing_1.isOfType)(comparison, toBetweenComparison) ? new SqlBetween(col, toSqlValue(comparison.between.lower), toSqlValue(comparison.between.upper)) : (0, typing_1.isOfType)(comparison, toLikeComparison) ? new SqlLike(col, toSqlValue(comparison.like)) : (0, typing_1.isOfType)(comparison, toInComparison) ? new SqlIn(col, comparison.in.map(toSqlValue)) : new SqlEquals(col, toSqlValue(comparison));
     };
     var SqlCondition = class _SqlCondition extends SqlCompositeCondition {
       static forTable(table, condition, paramIndexGen, dbSpec, transformer) {
@@ -141685,7 +141730,7 @@ var require_errors8 = __commonJS({
   "packages/team-service/common/lib/errors.js"(exports2) {
     "use strict";
     Object.defineProperty(exports2, "__esModule", { value: true });
-    exports2.changeMemberRoleFailed = exports2.deleteInviteFailed = exports2.teamUpdateFailed = exports2.sendInviteFailed = exports2.notEnoughSeats = exports2.fetchInvitationsFailed = exports2.fetchTeamsFailed = exports2.leaveTeamFailed = exports2.lastAdminError = exports2.checkAccessFailed = exports2.deleteTeamFailed = exports2.createTeamFailed = exports2.invalidInvitation = exports2.userIsNotMember = void 0;
+    exports2.changeMemberRoleFailed = exports2.deleteInviteFailed = exports2.teamUpdateFailed = exports2.fetchInvitationsFailed = exports2.fetchTeamsFailed = exports2.leaveTeamFailed = exports2.lastAdminError = exports2.checkAccessFailed = exports2.deleteTeamFailed = exports2.createTeamFailed = exports2.invalidInvitation = exports2.userIsNotMember = void 0;
     var userIsNotMember = (userId, teamId) => `User ${userId} is not authorized to access team ${teamId}.`;
     exports2.userIsNotMember = userIsNotMember;
     exports2.invalidInvitation = "Failed to accept invitation it is either expired or already accepted";
@@ -141696,8 +141741,6 @@ var require_errors8 = __commonJS({
     exports2.leaveTeamFailed = "Failed to leave team try again later";
     exports2.fetchTeamsFailed = "Failed to fetch your teams please try again later";
     exports2.fetchInvitationsFailed = "Failed to fetch your invitations please try again later";
-    exports2.notEnoughSeats = "Not enough seats to add more team members";
-    exports2.sendInviteFailed = "Failed to send invitation try again later";
     exports2.teamUpdateFailed = "Team update failed please try again later";
     exports2.deleteInviteFailed = "Failed to delete invitation it is either expired or already accepted";
     exports2.changeMemberRoleFailed = "Failed to change member role please try again later";
@@ -141717,8 +141760,10 @@ var require_team = __commonJS({
     var FetchMembersFailed_1;
     var IsLastAdmin_1;
     var ChangeMemberRoleFailed_1;
+    var NotEnoughSeats_1;
+    var SendInviteFailed_1;
     Object.defineProperty(exports2, "__esModule", { value: true });
-    exports2.TeamReplyStub = exports2.TeamStub = exports2.teamStub = exports2.teamService = exports2.teamServiceImpl = exports2.RemoveMemberFailed = exports2.ChangeMemberRoleFailed = exports2.IsLastAdmin = exports2.FetchMembersFailed = void 0;
+    exports2.TeamReplyStub = exports2.TeamStub = exports2.teamStub = exports2.teamService = exports2.teamServiceImpl = exports2.RemoveMemberFailed = exports2.SendInviteFailed = exports2.NotEnoughSeats = exports2.ChangeMemberRoleFailed = exports2.IsLastAdmin = exports2.FetchMembersFailed = void 0;
     var inversify_1 = require_inversify();
     var compat_1 = require_compat2();
     var spec_1 = require_spec2();
@@ -141758,6 +141803,24 @@ var require_team = __commonJS({
     exports2.ChangeMemberRoleFailed = ChangeMemberRoleFailed = ChangeMemberRoleFailed_1 = __decorate([
       (0, registry_1.registerError)()
     ], ChangeMemberRoleFailed);
+    var NotEnoughSeats = NotEnoughSeats_1 = class NotEnoughSeats extends exceptions_1.SimpleSerializableException {
+      static create(opts) {
+        return new NotEnoughSeats_1("Not enough seats to add more team members", opts);
+      }
+    };
+    exports2.NotEnoughSeats = NotEnoughSeats;
+    exports2.NotEnoughSeats = NotEnoughSeats = NotEnoughSeats_1 = __decorate([
+      (0, registry_1.registerError)()
+    ], NotEnoughSeats);
+    var SendInviteFailed = SendInviteFailed_1 = class SendInviteFailed extends exceptions_1.SimpleSerializableException {
+      static create(opts) {
+        return new SendInviteFailed_1("Failed to send invitation try again later", opts);
+      }
+    };
+    exports2.SendInviteFailed = SendInviteFailed;
+    exports2.SendInviteFailed = SendInviteFailed = SendInviteFailed_1 = __decorate([
+      (0, registry_1.registerError)()
+    ], SendInviteFailed);
     var RemoveMemberFailed = class RemoveMemberFailed extends exceptions_1.SimpleSerializableException {
     };
     exports2.RemoveMemberFailed = RemoveMemberFailed;
@@ -141799,6 +141862,11 @@ var require_team = __commonJS({
           request: TeamServiceArgs_1.toChangeRoleArgs,
           response: typing_2.toVoid
         }),
+        sendInvite: (0, spec_2.rpc)({
+          access: "public",
+          request: TeamServiceArgs_1.toSendInviteArgs,
+          response: typing_2.toVoid
+        }),
         removeMember: (0, spec_2.rpc)({
           access: "public",
           request: TeamServiceArgs_1.toRemoveMemberArgs,
@@ -141847,11 +141915,6 @@ var require_team = __commonJS({
           request: TeamServiceArgs_1.toTeamServiceArgs,
           response: typing_2.toVoid
         }),
-        sendInvite: (0, spec_2.rpc)({
-          access: "public",
-          request: TeamServiceArgs_1.toSendInviteArgs,
-          response: typing_2.toVoid
-        }),
         acceptInvite: (0, spec_2.rpc)({
           access: "public",
           request: TeamServiceArgs_1.toTeamServiceArgs,
@@ -141933,13 +141996,14 @@ var require_pipeline3 = __commonJS({
       return c > 3 && r && Object.defineProperty(target, key, r), r;
     };
     Object.defineProperty(exports2, "__esModule", { value: true });
-    exports2.PipelineProxyStub = exports2.pipelineProxyService = exports2.toRemoveEnvironmentVariablesArgs = exports2.toSetEnvironmentVariablesArgs = exports2.toSetConfigArgs = void 0;
+    exports2.PipelineProxyStub = exports2.pipelineProxyService = exports2.toPipelineStreamArgs = exports2.toRemoveEnvironmentVariablesArgs = exports2.toSetEnvironmentVariablesArgs = exports2.toSetConfigArgs = void 0;
     var inversify_1 = require_inversify();
     var spec_1 = require_spec2();
     var typing_1 = require_typing3();
     var spec_2 = require_spec();
     var datetime_1 = require_datetime();
     var typing_2 = require_typing();
+    var number_1 = require_number();
     var pipeline_1 = require_pipeline();
     var logging_12 = require_logging3();
     var types_1 = require_types5();
@@ -141951,7 +142015,7 @@ var require_pipeline3 = __commonJS({
     });
     exports2.toSetConfigArgs = (0, typing_2.toObject)({
       ...serviceArgs_1.workspaceServiceArgs,
-      pipeline: types_1.toPipelineConfig,
+      pipeline: (0, typing_2.toNullOr)(types_1.toPipelineConfig),
       profile: (0, typing_2.toUndefOr)(typing_2.toString)
     });
     exports2.toSetEnvironmentVariablesArgs = (0, typing_2.toObject)({
@@ -141979,14 +142043,18 @@ var require_pipeline3 = __commonJS({
       replica: (0, typing_2.toUndefOr)(typing_2.toString),
       server: (0, typing_2.toUndefOr)(typing_2.toString)
     });
+    exports2.toPipelineStreamArgs = (0, typing_2.toObject)({
+      workspaceId: number_1.toPositiveInteger,
+      profile: (0, typing_2.toUndefOr)(typing_2.toString)
+    });
     exports2.pipelineProxyService = {
       name: "PipelineProxy",
       context: typing_1.toHttpContext,
       methods: {
         pipelineStream: (0, spec_2.stream)({
           access: "public",
           response: (0, typing_2.toNullOr)(types_1.toPipelineConfig),
-          request: serviceArgs_1.toWorkspaceServiceArgs
+          request: exports2.toPipelineStreamArgs
         }),
         setPipeline: (0, spec_2.rpc)({
           access: "public",
@@ -142029,6 +142097,11 @@ var require_pipeline3 = __commonJS({
           access: "public",
           response: types_1.toStageExecutionInfo,
           request: toExecInfoArgs
+        }),
+        pipelineProfiles: (0, spec_2.stream)({
+          access: "public",
+          response: (0, typing_2.toArray)(typing_2.toString),
+          request: serviceArgs_1.toWorkspaceServiceArgs
         })
       }
     };