Merge pull request #22920 from RoadieHQ/deprecations

Fix some deprecations and misplaced await usage.
This commit is contained in:
Ben Lambert
2024-02-14 14:53:03 +01:00
committed by GitHub
12 changed files with 63 additions and 50 deletions
+10 -10
View File
@@ -78,9 +78,9 @@ export const createBuiltinActions: (
// @public
export interface CreateBuiltInActionsOptions {
additionalTemplateFilters?: Record<string, TemplateFilter>;
additionalTemplateFilters?: Record<string, TemplateFilter_2>;
// (undocumented)
additionalTemplateGlobals?: Record<string, TemplateGlobal>;
additionalTemplateGlobals?: Record<string, TemplateGlobal_2>;
catalogClient: CatalogApi;
config: Config;
integrations: ScmIntegrations;
@@ -169,8 +169,8 @@ export function createFetchPlainFileAction(options: {
export function createFetchTemplateAction(options: {
reader: UrlReader;
integrations: ScmIntegrations;
additionalTemplateFilters?: Record<string, TemplateFilter>;
additionalTemplateGlobals?: Record<string, TemplateGlobal>;
additionalTemplateFilters?: Record<string, TemplateFilter_2>;
additionalTemplateGlobals?: Record<string, TemplateGlobal_2>;
}): TemplateAction_2<
{
url: string;
@@ -343,14 +343,14 @@ export function createWaitAction(options?: {
// @public
export type CreateWorkerOptions = {
taskBroker: TaskBroker;
taskBroker: TaskBroker_2;
actionRegistry: TemplateActionRegistry;
integrations: ScmIntegrations;
workingDirectory: string;
logger: Logger;
additionalTemplateFilters?: Record<string, TemplateFilter>;
additionalTemplateFilters?: Record<string, TemplateFilter_2>;
concurrentTasksLimit?: number;
additionalTemplateGlobals?: Record<string, TemplateGlobal>;
additionalTemplateGlobals?: Record<string, TemplateGlobal_2>;
permissions?: PermissionEvaluator;
};
@@ -500,11 +500,11 @@ export type TaskContext = TaskContext_2;
export type TaskEventType = TaskEventType_2;
// @public
export class TaskManager implements TaskContext {
export class TaskManager implements TaskContext_2 {
// (undocumented)
get cancelSignal(): AbortSignal;
// (undocumented)
complete(result: TaskCompletionState, metadata?: JsonObject): Promise<void>;
complete(result: TaskCompletionState_2, metadata?: JsonObject): Promise<void>;
// (undocumented)
static create(
task: CurrentClaimedTask,
@@ -619,7 +619,7 @@ export class TaskWorker {
// (undocumented)
recoverTasks(): Promise<void>;
// (undocumented)
runOneTask(task: TaskContext): Promise<void>;
runOneTask(task: TaskContext_2): Promise<void>;
// (undocumented)
start(): void;
// (undocumented)
@@ -16,8 +16,10 @@
import { parseEntityRef } from '@backstage/catalog-model';
import { ScmIntegrations } from '@backstage/integration';
import type { JsonObject, JsonValue } from '@backstage/types';
import { TemplateFilter } from '..';
import { parseRepoUrl } from '@backstage/plugin-scaffolder-node';
import {
parseRepoUrl,
TemplateFilter,
} from '@backstage/plugin-scaffolder-node';
import get from 'lodash/get';
export const createDefaultFilters = ({
@@ -22,14 +22,17 @@ import {
GithubCredentialsProvider,
ScmIntegrations,
} from '@backstage/integration';
import { TemplateAction } from '@backstage/plugin-scaffolder-node';
import {
TemplateAction,
TemplateFilter,
TemplateGlobal,
} from '@backstage/plugin-scaffolder-node';
import {
createCatalogRegisterAction,
createCatalogWriteAction,
createFetchCatalogEntityAction,
} from './catalog';
import { TemplateFilter, TemplateGlobal } from '../../../lib';
import { createDebugLogAction, createWaitAction } from './debug';
import {
createFetchPlainAction,
@@ -21,15 +21,13 @@ import { ScmIntegrations } from '@backstage/integration';
import {
createTemplateAction,
fetchContents,
TemplateFilter,
TemplateGlobal,
} from '@backstage/plugin-scaffolder-node';
import globby from 'globby';
import fs from 'fs-extra';
import { isBinaryFile } from 'isbinaryfile';
import {
TemplateFilter,
SecureTemplater,
TemplateGlobal,
} from '../../../../lib/templating/SecureTemplater';
import { SecureTemplater } from '../../../../lib/templating/SecureTemplater';
import { createDefaultFilters } from '../../../../lib/templating/filters';
import { examples } from './template.examples';
@@ -19,12 +19,12 @@ import { NunjucksWorkflowRunner } from './NunjucksWorkflowRunner';
import { TemplateActionRegistry } from '../actions';
import { ScmIntegrations } from '@backstage/integration';
import { ConfigReader } from '@backstage/config';
import { TaskContext } from './types';
import { TaskSpec } from '@backstage/plugin-scaffolder-common';
import {
createTemplateAction,
TaskSecrets,
TemplateAction,
TaskContext,
} from '@backstage/plugin-scaffolder-node';
import { UserEntity } from '@backstage/catalog-model';
import { z } from 'zod';
@@ -15,12 +15,7 @@
*/
import { ScmIntegrations } from '@backstage/integration';
import {
TaskContext,
TaskTrackType,
WorkflowResponse,
WorkflowRunner,
} from './types';
import { TaskTrackType, WorkflowResponse, WorkflowRunner } from './types';
import * as winston from 'winston';
import fs from 'fs-extra';
import path from 'path';
@@ -32,10 +27,8 @@ import { generateExampleOutput, isTruthy } from './helper';
import { validate as validateJsonSchema } from 'jsonschema';
import { TemplateActionRegistry } from '../actions';
import {
TemplateFilter,
SecureTemplater,
SecureTemplateRenderer,
TemplateGlobal,
} from '../../lib/templating/SecureTemplater';
import {
TaskSpec,
@@ -43,7 +36,12 @@ import {
TaskStep,
} from '@backstage/plugin-scaffolder-common';
import { TemplateAction } from '@backstage/plugin-scaffolder-node';
import {
TemplateAction,
TemplateFilter,
TemplateGlobal,
TaskContext,
} from '@backstage/plugin-scaffolder-node';
import { createConditionAuthorizer } from '@backstage/plugin-permission-node';
import { UserEntity } from '@backstage/catalog-model';
import { createCounterMetric, createHistogramMetric } from '../../util/metrics';
@@ -226,7 +224,7 @@ export class NunjucksWorkflowRunner implements WorkflowRunner {
try {
if (step.if) {
const ifResult = await this.render(step.if, context, renderTemplate);
const ifResult = this.render(step.if, context, renderTemplate);
if (!isTruthy(ifResult)) {
await stepTrack.skipFalsy();
return;
@@ -17,10 +17,12 @@
import { getVoidLogger, DatabaseManager } from '@backstage/backend-common';
import { ConfigReader } from '@backstage/config';
import { TaskSpec } from '@backstage/plugin-scaffolder-common';
import { TaskSecrets } from '@backstage/plugin-scaffolder-node';
import {
TaskSecrets,
SerializedTaskEvent,
} from '@backstage/plugin-scaffolder-node';
import { DatabaseTaskStore } from './DatabaseTaskStore';
import { StorageTaskBroker, TaskManager } from './StorageTaskBroker';
import { SerializedTaskEvent } from './types';
async function createStore(): Promise<DatabaseTaskStore> {
const manager = DatabaseManager.fromConfig(
@@ -81,12 +83,12 @@ describe('StorageTaskBroker', () => {
const taskA = await broker.claim();
const taskB = await broker.claim();
const taskC = await broker.claim();
await expect(taskA).toEqual(expect.any(TaskManager as any));
await expect(taskB).toEqual(expect.any(TaskManager as any));
await expect(taskC).toEqual(expect.any(TaskManager as any));
await expect(taskA.spec.steps[0].id).toBe('a');
await expect(taskB.spec.steps[0].id).toBe('b');
await expect(taskC.spec.steps[0].id).toBe('c');
expect(taskA).toEqual(expect.any(TaskManager as any));
expect(taskB).toEqual(expect.any(TaskManager as any));
expect(taskC).toEqual(expect.any(TaskManager as any));
expect(taskA.spec.steps[0].id).toBe('a');
expect(taskB.spec.steps[0].id).toBe('b');
expect(taskC.spec.steps[0].id).toBe('c');
});
it('should store secrets', async () => {
@@ -16,19 +16,19 @@
import { Config } from '@backstage/config';
import { TaskSpec } from '@backstage/plugin-scaffolder-common';
import { TaskSecrets } from '@backstage/plugin-scaffolder-node';
import { JsonObject, Observable } from '@backstage/types';
import { Logger } from 'winston';
import ObservableImpl from 'zen-observable';
import {
TaskSecrets,
SerializedTask,
SerializedTaskEvent,
TaskBroker,
TaskBrokerDispatchOptions,
TaskCompletionState,
TaskContext,
TaskStore,
} from './types';
} from '@backstage/plugin-scaffolder-node';
import { JsonObject, Observable } from '@backstage/types';
import { Logger } from 'winston';
import ObservableImpl from 'zen-observable';
import { TaskStore } from './types';
import { readDuration } from './helper';
/**
@@ -27,8 +27,8 @@ import {
SerializedTaskEvent,
TaskBroker,
TaskContext,
WorkflowRunner,
} from './types';
} from '@backstage/plugin-scaffolder-node';
import { WorkflowRunner } from './types';
import ObservableImpl from 'zen-observable';
import waitForExpect from 'wait-for-expect';
@@ -257,7 +257,7 @@ describe('Cancellable TaskWorker', () => {
},
});
await taskWorker.start();
taskWorker.start();
await taskBroker.cancel(taskId);
await waitForExpect(() => {
@@ -14,14 +14,19 @@
* limitations under the License.
*/
import { TaskContext, TaskBroker, WorkflowRunner } from './types';
import { WorkflowRunner } from './types';
import {
TaskContext,
TaskBroker,
TemplateFilter,
TemplateGlobal,
} from '@backstage/plugin-scaffolder-node';
import PQueue from 'p-queue';
import { NunjucksWorkflowRunner } from './NunjucksWorkflowRunner';
import { Logger } from 'winston';
import { TemplateActionRegistry } from '../actions';
import { ScmIntegrations } from '@backstage/integration';
import { assertError, stringifyError } from '@backstage/errors';
import { TemplateFilter, TemplateGlobal } from '../../lib';
import { PermissionEvaluator } from '@backstage/plugin-permission-common';
/**
@@ -15,7 +15,7 @@
*/
import { trimEventsTillLastRecovery } from './taskRecoveryHelper';
import { SerializedTaskEvent } from './types';
import { SerializedTaskEvent } from '@backstage/plugin-scaffolder-node';
const toLogEvent = (stepId: string) =>
({