Skip to content
Closed

temp #454

Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 32 additions & 5 deletions dist/helpers/index.js
Original file line number Diff line number Diff line change
@@ -1,12 +1,39 @@
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.forgivingJSONParse = exports.createClient = void 0;
const dynamodb_1 = require("aws-sdk/clients/dynamodb");
const vm = require("vm");
const client_dynamodb_1 = require("@aws-sdk/client-dynamodb");
const lib_dynamodb_1 = require("@aws-sdk/lib-dynamodb");
const vm = __importStar(require("vm"));
function createClient(endpoint) {
return /^https?/i.test(endpoint) ?
new dynamodb_1.DocumentClient({ endpoint, region: "us-east-1" }) :
new dynamodb_1.DocumentClient({ region: endpoint });
const client = /^https?/i.test(endpoint) ?
new client_dynamodb_1.DynamoDBClient({ endpoint, region: "us-east-1" }) :
new client_dynamodb_1.DynamoDBClient({ region: endpoint });
return lib_dynamodb_1.DynamoDBDocumentClient.from(client, {
marshallOptions: { removeUndefinedValues: true }
});
}
exports.createClient = createClient;
function forgivingJSONParse(input) {
Expand Down
27 changes: 25 additions & 2 deletions dist/index.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,30 @@
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
const axios_1 = require("axios");
const core = require("@actions/core");
const axios_1 = __importStar(require("axios"));
const core = __importStar(require("@actions/core"));
const helpers_1 = require("./helpers");
const processor_1 = require("./processor");
const processor = new processor_1.Processor();
Expand Down
32 changes: 28 additions & 4 deletions dist/operations/batch-put.js
Original file line number Diff line number Diff line change
@@ -1,8 +1,32 @@
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.BatchPutOperation = void 0;
const glob = require("@actions/glob");
const Joi = require("@hapi/joi");
const glob = __importStar(require("@actions/glob"));
const Joi = __importStar(require("@hapi/joi"));
const lib_dynamodb_1 = require("@aws-sdk/lib-dynamodb");
const fs_1 = require("fs");
const helpers_1 = require("../helpers");
const BaseInputSchema = Joi.object({
Expand Down Expand Up @@ -37,15 +61,15 @@ class BatchPutOperation {
const items = input.items || await this.read(input.files);
const chunks = this.chunk(items, 20);
for (const chunk of chunks) {
const res = await ddb.batchWrite({
const res = await ddb.send(new lib_dynamodb_1.BatchWriteCommand({
RequestItems: {
[input.table]: chunk.map((item) => ({
PutRequest: {
Item: item,
},
})),
},
}).promise();
}));
const failedItems = (_b = (_a = res.UnprocessedItems) === null || _a === void 0 ? void 0 : _a[input.table]) !== null && _b !== void 0 ? _b : [];
if (failedItems.length > 0) {
console.error("UnprocessedItems: ", res.UnprocessedItems); // tslint:disable-line
Expand Down
30 changes: 27 additions & 3 deletions dist/operations/delete.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,31 @@
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.DeleteOperation = void 0;
const Joi = require("@hapi/joi");
const Joi = __importStar(require("@hapi/joi"));
const lib_dynamodb_1 = require("@aws-sdk/lib-dynamodb");
const helpers_1 = require("../helpers");
const InputSchema = Joi.object({
operation: Joi.string().lowercase().valid("delete").required(),
Expand All @@ -24,10 +48,10 @@ class DeleteOperation {
}
async execute(input) {
const ddb = (0, helpers_1.createClient)(input.region);
await ddb.delete({
await ddb.send(new lib_dynamodb_1.DeleteCommand({
TableName: input.table,
Key: input.key,
}).promise();
}));
}
}
exports.DeleteOperation = DeleteOperation;
30 changes: 27 additions & 3 deletions dist/operations/get.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,31 @@
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.GetOperation = void 0;
const Joi = require("@hapi/joi");
const Joi = __importStar(require("@hapi/joi"));
const lib_dynamodb_1 = require("@aws-sdk/lib-dynamodb");
const helpers_1 = require("../helpers");
const InputSchema = Joi.object({
operation: Joi.string().lowercase().valid("get").required(),
Expand All @@ -25,11 +49,11 @@ class GetOperation {
}
async execute(input) {
const ddb = (0, helpers_1.createClient)(input.region);
const res = await ddb.get({
const res = await ddb.send(new lib_dynamodb_1.GetCommand({
TableName: input.table,
Key: input.key,
ConsistentRead: !!input.consistent,
}).promise();
}));
return { item: JSON.stringify(res.Item) };
}
}
Expand Down
30 changes: 27 additions & 3 deletions dist/operations/put.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,31 @@
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.PutOperation = void 0;
const Joi = require("@hapi/joi");
const Joi = __importStar(require("@hapi/joi"));
const lib_dynamodb_1 = require("@aws-sdk/lib-dynamodb");
const fs_1 = require("fs");
const helpers_1 = require("../helpers");
const BaseInputSchema = Joi.object({
Expand Down Expand Up @@ -33,10 +57,10 @@ class PutOperation {
async execute(input) {
const ddb = (0, helpers_1.createClient)(input.region);
const item = input.item || await this.read(input.file);
await ddb.put({
await ddb.send(new lib_dynamodb_1.PutCommand({
TableName: input.table,
Item: item,
}).promise();
}));
}
async read(path) {
const content = await fs_1.promises.readFile(path, { encoding: "utf8" });
Expand Down
Loading
Loading