Skip to content

Adds list configs to manager #555

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 3 commits into from
Jan 23, 2018
Merged

Adds list configs to manager #555

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
738c5db
Adds list configs to manager
gguuss Jan 16, 2018
a8bd97d
Merge branch 'master' into iot-list-configs
gguuss Jan 16, 2018
afcbfeb
Adds IAM examples
gguuss Jan 18, 2018
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
140 changes: 140 additions & 0 deletions iot/manager/manager.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -573,6 +573,34 @@ function getDeviceState (client, deviceId, registryId, projectId,
// [END iot_get_device_state]
}

// Retrieve the given device's configuration history from the registry.
function getDeviceConfigs (client, deviceId, registryId, projectId,
cloudRegion) {
// [START iot_get_device_configs]
// Client retrieved in callback
// getClient(serviceAccountJson, function(client) {...});
// const cloudRegion = 'us-central1';
// const deviceId = 'my-device';
// const projectId = 'adjective-noun-123';
// const registryId = 'my-registry';
const parentName = `projects/${projectId}/locations/${cloudRegion}`;
const registryName = `${parentName}/registries/${registryId}`;
const request = {
name: `${registryName}/devices/${deviceId}`
};

client.projects.locations.registries.devices.configVersions.list(request,
(err, data) => {
if (err) {
console.log('Could not find device:', deviceId);
console.log(err);
} else {
console.log('Configs:', data);
}
});
// [END iot_get_device_configs]
}

// Retrieve the given device's state from the registry.
function setDeviceConfig (client, deviceId, registryId, projectId,
cloudRegion, data, version) {
Expand Down Expand Up @@ -656,6 +684,80 @@ function getClient (serviceAccountJson, cb) {
});
}

// Retrieves the IAM policy for a given registry.
function getIamPolicy (client, registryId, projectId, cloudRegion) {
// [START iot_get_iam_policy]
// Client retrieved in callback
// getClient(serviceAccountJson, function(client) {...});
// const cloudRegion = 'us-central1';
// const projectId = 'adjective-noun-123';
// const registryId = 'my-registry';
const parentName = `projects/${projectId}/locations/${cloudRegion}`;
const registryName = `${parentName}/registries/${registryId}`;
const request = {
'resource_': `${registryName}`
};

client.projects.locations.registries.getIamPolicy(request, (err, data) => {
if (err) {
console.log('Could not find policy for: ', registryId);
console.log('Trace: ', err);
} else {
console.log(`ETAG: ${data.etag}`);
data.bindings = data.bindings || [];
data.bindings.forEach((_binding) => {
console.log(`Role: ${_binding.role}`);
_binding.members || (_binding.members = []);
_binding.members.forEach((_member) => {
console.log(`\t${_member}`);
});
});
}
});
// [END iot_get_iam_policy]
}

// Sets the IAM permissions for a given registry to a single member / role.
function setIamPolicy (client, registryId, projectId, cloudRegion, member,
role) {
// [START iot_set_iam_policy]
// Client retrieved in callback
// setClient(serviceAccountJson, function(client) {...});
// const cloudRegion = 'us-central1';
// const projectId = 'adjective-noun-123';
// const registryId = 'my-registry';
const parentName = `projects/${projectId}/locations/${cloudRegion}`;
const registryName = `${parentName}/registries/${registryId}`;
const request = {
'resource_': `${registryName}`,
'resource': {'policy': {
'bindings': [{
'members': member,
'role': role
}]
}}
};

client.projects.locations.registries.setIamPolicy(request, (err, data) => {
if (err) {
console.log('Could not set policy for: ', registryId);
console.log('Trace: ', err);
} else {
console.log(`ETAG: ${data.etag}`);
console.log(JSON.stringify(data));
data.bindings = data.bindings || [];
data.bindings.forEach((_binding) => {
console.log(`Role: ${_binding.role}`);
_binding.members || (_binding.members = []);
_binding.members.forEach((_member) => {
console.log(`\t${_member}`);
});
});
}
});
// [END iot_set_iam_policy]
}

require(`yargs`) // eslint-disable-line
.demand(1)
.options({
Expand Down Expand Up @@ -788,6 +890,18 @@ require(`yargs`) // eslint-disable-line
getClient(opts.serviceAccount, cb);
}
)
.command(
`getDeviceConfigs <deviceId> <registryId>`,
`Retrieves device configurations given a device ID.`,
{},
(opts) => {
const cb = function (client) {
getDeviceConfigs(client, opts.deviceId, opts.registryId, opts.projectId,
opts.cloudRegion);
};
getClient(opts.serviceAccount, cb);
}
)
.command(
`getDeviceState <deviceId> <registryId>`,
`Retrieves device state given a device ID.`,
Expand Down Expand Up @@ -870,6 +984,30 @@ require(`yargs`) // eslint-disable-line
getClient(opts.serviceAccount, cb);
}
)
.command(
`getIamPolicy <registryId>`,
`Gets the IAM permissions for a given registry`,
{},
(opts) => {
const cb = function (client) {
getIamPolicy(client, opts.registryId, opts.projectId,
opts.cloudRegion);
};
getClient(opts.serviceAccount, cb);
}
)
.command(
`setIamPolicy <registryId> <member> <role>`,
`Gets the IAM permissions for a given registry`,
{},
(opts) => {
const cb = function (client) {
setIamPolicy(client, opts.registryId, opts.projectId,
opts.cloudRegion, opts.member, opts.role);
};
getClient(opts.serviceAccount, cb);
}
)
.example(`node $0 createEs256Device my-es-device my-registry ../ec_public.pem`)
.example(`node $0 createRegistry my-registry my-iot-topic --serviceAccount=$HOME/creds_iot.json --project_id=my-project-id`)
.example(`node $0 createRsa256Device my-rsa-device my-registry ../rsa_cert.pem`)
Expand All @@ -878,12 +1016,14 @@ require(`yargs`) // eslint-disable-line
.example(`node $0 deleteRegistry my-device my-registry`)
.example(`node $0 getDevice my-device my-registry`)
.example(`node $0 getDeviceState my-device my-registry`)
.example(`node $0 getIamPolicy my-registry`)
.example(`node $0 getRegistry my-registry`)
.example(`node $0 listDevices my-node-registry`)
.example(`node $0 listRegistries`)
.example(`node $0 patchRsa256 my-device my-registry ../rsa_cert.pem`)
.example(`node $0 patchEs256 my-device my-registry ../ec_public.pem`)
.example(`node $0 setConfig my-device my-registry "test" 0`)
.example(`node $0 setIamPolicy my-registry user:[email protected] roles/viewer`)
.example(`node $0 setupTopic my-iot-topic --serviceAccount=$HOME/creds_iot.json --projectId=my-project-id`)
.wrap(120)
.recommendCommands()
Expand Down
33 changes: 33 additions & 0 deletions iot/manager/system-test/manager.test.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,24 @@ test(`should create and delete an unauthorized device`, async (t) => {
output = await tools.runAsync(`${cmd} deleteRegistry ${localRegName}`, cwd);
});

test(`should list configs for a device`, async (t) => {
const localDevice = `test-device-configs`;
const localRegName = `${registryName}-unauth`;
let output = await tools.runAsync(`${cmd} setupIotTopic ${topicName}`, cwd);
output = await tools.runAsync(
`${cmd} createRegistry ${localRegName} ${topicName}`, cwd);
output = await tools.runAsync(
`${cmd} createUnauthDevice ${localDevice} ${localRegName}`, cwd);
t.regex(output, new RegExp(`Created device`));
output = await tools.runAsync(
`${cmd} getDeviceConfigs ${localDevice} ${localRegName}`, cwd);
t.regex(output, new RegExp(`Configs`));
output = await tools.runAsync(
`${cmd} deleteDevice ${localDevice} ${localRegName}`, cwd);
t.regex(output, new RegExp(`Successfully deleted device`));
output = await tools.runAsync(`${cmd} deleteRegistry ${localRegName}`, cwd);
});

test(`should create and delete an RSA256 device`, async (t) => {
const localDevice = `test-rsa-device`;
const localRegName = `${registryName}-rsa256`;
Expand Down Expand Up @@ -170,6 +188,21 @@ test(`should create and get a device`, async (t) => {
output = await tools.runAsync(`${cmd} deleteRegistry ${localRegName}`, cwd);
});

test(`should create and get an iam policy`, async (t) => {
const localMember = `group:[email protected]`;
const localRole = `roles/viewer`;
const localRegName = `${registryName}-get`;
let output = await tools.runAsync(`${cmd} setupIotTopic ${topicName}`, cwd);
output = await tools.runAsync(
`${cmd} createRegistry ${localRegName} ${topicName}`, cwd);
output = await tools.runAsync(
`${cmd} setIamPolicy ${localRegName} ${localMember} ${localRole}`, cwd);
t.regex(output, new RegExp(`ETAG`));
output = await tools.runAsync(`${cmd} getIamPolicy ${localRegName}`, cwd);
t.regex(output, new RegExp(`dpebot`));
output = await tools.runAsync(`${cmd} deleteRegistry ${localRegName}`, cwd);
});

test(`should create and delete a registry`, async (t) => {
let output = await tools.runAsync(`${cmd} setupIotTopic ${topicName}`, cwd);
output = await tools.runAsync(
Expand Down