Skip to content

Commit

Permalink
some adjusts
Browse files Browse the repository at this point in the history
  • Loading branch information
luancazarine committed Sep 19, 2024
1 parent 1829184 commit b9be91e
Show file tree
Hide file tree
Showing 3 changed files with 30 additions and 31 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,24 +21,20 @@ export default {
},
},
async run({ $ }) {
let start = 0;
const count = 50;
const results = [];

const params = {
q: "organization",
organization: encodeURI(this.organizationUrn),
start: 0,
count,
};
const params = `q=organization&organization=${this.organizationUrn.replace(/:/g, "%3A")}&count=${count}`;

let done = false;
do {
const { elements } = await this.linkedin.getAccessControl({
$,
params,
const { data: { elements } } = await this.linkedin.getAccessControl({
params: params + `&start=${start}`,
});

results.push(...elements);
params.start += count;
start += count;
if (elements?.length < count) {
done = true;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,26 +21,20 @@ export default {
},
},
async run({ $ }) {
let start = 0;
const count = 50;
const results = [];

const params = {
q: "organization",
organization: encodeURI(this.organizationUrn),
role: "ADMINISTRATOR",
state: "APPROVED",
start: 0,
count,
};
const params = `q=organization&organization=${this.organizationUrn.replace(/:/g, "%3A")}&role=ADMINISTRATOR&state=APPROVED&count=${count}`;

let done = false;
do {
const { elements } = await this.linkedin.getAccessControl({
$,
params,
const { data: { elements } } = await this.linkedin.getAccessControl({
params: params + `&start=${start}`,
});

results.push(...elements);
params.start += count;
start += count;
if (elements?.length < count) {
done = true;
}
Expand Down
27 changes: 18 additions & 9 deletions components/linkedin/linkedin.app.mjs
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
import { axios } from "@pipedream/platform";
import { axios as axiosPD } from "@pipedream/platform";
import axios from "axios";
import constants from "./common/constants.mjs";

export default {
Expand Down Expand Up @@ -45,7 +46,7 @@ export default {
});
return elements?.map((element) => ({
label: element.name,
id: element.id,
value: element.id,
}));
},
},
Expand Down Expand Up @@ -138,13 +139,22 @@ export default {
}) {
const BASE_URL = constants.BASE_URL;

const config = {
return axiosPD($ || this, {
url: url || `${BASE_URL}${constants.VERSION_PATH}${path}`,
headers: this._getHeaders(),
...otherConfig,
};
});
},
async _makeRequestAxios({
url, path, ...otherConfig
}) {
const BASE_URL = constants.BASE_URL;

return axios($ || this, config);
return axios({
url: url || `${BASE_URL}${constants.VERSION_PATH}${path}`,
headers: this._getHeaders(),
...otherConfig,
});
},
async createPost({
data, ...args
Expand Down Expand Up @@ -223,10 +233,9 @@ export default {
...args,
});
},
async getAccessControl(args = {}) {
return this._makeRequest({
path: "/organizationAcls",
...args,
async getAccessControl({ params }) {
return this._makeRequestAxios({
path: `/organizationAcls?${params}`,
});
},
async queryAnaltyics(query, args = {} ) {
Expand Down

0 comments on commit b9be91e

Please sign in to comment.