| 1 | var once = require('once'),
|
| 2 | db = require('../db')
|
| 3 |
|
| 4 | module.exports = function listTagsOfResource(store, data, cb) {
|
| 5 | cb = once(cb)
|
| 6 |
|
| 7 | var tableName = data.ResourceArn.split('/').pop()
|
| 8 |
|
| 9 | store.getTable(tableName, false, function(err) {
|
| 10 | if (err && err.name == 'NotFoundError') {
|
| 11 | err.body.message = 'Requested resource not found: ResourcArn: ' + data.ResourceArn + ' not found'
|
| 12 | }
|
| 13 | if (err) return cb(err)
|
| 14 |
|
| 15 | db.lazy(store.getTagDb(tableName).createReadStream(), cb).join(function(tags) {
|
| 16 | cb(null, {Tags: tags.map(function(tag) { return {Key: tag.key, Value: tag.value} })})
|
| 17 | })
|
| 18 | })
|
| 19 | }
|
| 20 |
|