Edit File: dockerSocket.js
'use strict'; // @ts-check // ================================================================================== // dockerSockets.js // ---------------------------------------------------------------------------------- // Description: System Information - library // for Node.js // Copyright: (c) 2014 - 2024 // Author: Sebastian Hildebrandt // ---------------------------------------------------------------------------------- // License: MIT // ================================================================================== // 13. DockerSockets // ---------------------------------------------------------------------------------- const net = require('net'); const isWin = require('os').type() === 'Windows_NT'; const socketPath = isWin ? '//./pipe/docker_engine' : '/var/run/docker.sock'; class DockerSocket { getInfo(callback) { try { let socket = net.createConnection({ path: socketPath }); let alldata = ''; let data; socket.on('connect', () => { socket.write('GET http:/info HTTP/1.0\r\n\r\n'); }); socket.on('data', data => { alldata = alldata + data.toString(); }); socket.on('error', () => { socket = false; callback({}); }); socket.on('end', () => { let startbody = alldata.indexOf('\r\n\r\n'); alldata = alldata.substring(startbody + 4); socket = false; try { data = JSON.parse(alldata); callback(data); } catch (err) { callback({}); } }); } catch (err) { callback({}); } } listImages(all, callback) { try { let socket = net.createConnection({ path: socketPath }); let alldata = ''; let data; socket.on('connect', () => { socket.write('GET http:/images/json' + (all ? '?all=1' : '') + ' HTTP/1.0\r\n\r\n'); }); socket.on('data', data => { alldata = alldata + data.toString(); }); socket.on('error', () => { socket = false; callback({}); }); socket.on('end', () => { let startbody = alldata.indexOf('\r\n\r\n'); alldata = alldata.substring(startbody + 4); socket = false; try { data = JSON.parse(alldata); callback(data); } catch (err) { callback({}); } }); } catch (err) { callback({}); } } inspectImage(id, callback) { id = id || ''; if (id) { try { let socket = net.createConnection({ path: socketPath }); let alldata = ''; let data; socket.on('connect', () => { socket.write('GET http:/images/' + id + '/json?stream=0 HTTP/1.0\r\n\r\n'); }); socket.on('data', data => { alldata = alldata + data.toString(); }); socket.on('error', () => { socket = false; callback({}); }); socket.on('end', () => { let startbody = alldata.indexOf('\r\n\r\n'); alldata = alldata.substring(startbody + 4); socket = false; try { data = JSON.parse(alldata); callback(data); } catch (err) { callback({}); } }); } catch (err) { callback({}); } } else { callback({}); } } listContainers(all, callback) { try { let socket = net.createConnection({ path: socketPath }); let alldata = ''; let data; socket.on('connect', () => { socket.write('GET http:/containers/json' + (all ? '?all=1' : '') + ' HTTP/1.0\r\n\r\n'); }); socket.on('data', data => { alldata = alldata + data.toString(); }); socket.on('error', () => { socket = false; callback({}); }); socket.on('end', () => { let startbody = alldata.indexOf('\r\n\r\n'); alldata = alldata.substring(startbody + 4); socket = false; try { data = JSON.parse(alldata); callback(data); } catch (err) { callback({}); } }); } catch (err) { callback({}); } } getStats(id, callback) { id = id || ''; if (id) { try { let socket = net.createConnection({ path: socketPath }); let alldata = ''; let data; socket.on('connect', () => { socket.write('GET http:/containers/' + id + '/stats?stream=0 HTTP/1.0\r\n\r\n'); }); socket.on('data', data => { alldata = alldata + data.toString(); }); socket.on('error', () => { socket = false; callback({}); }); socket.on('end', () => { let startbody = alldata.indexOf('\r\n\r\n'); alldata = alldata.substring(startbody + 4); socket = false; try { data = JSON.parse(alldata); callback(data); } catch (err) { callback({}); } }); } catch (err) { callback({}); } } else { callback({}); } } getInspect(id, callback) { id = id || ''; if (id) { try { let socket = net.createConnection({ path: socketPath }); let alldata = ''; let data; socket.on('connect', () => { socket.write('GET http:/containers/' + id + '/json?stream=0 HTTP/1.0\r\n\r\n'); }); socket.on('data', data => { alldata = alldata + data.toString(); }); socket.on('error', () => { socket = false; callback({}); }); socket.on('end', () => { let startbody = alldata.indexOf('\r\n\r\n'); alldata = alldata.substring(startbody + 4); socket = false; try { data = JSON.parse(alldata); callback(data); } catch (err) { callback({}); } }); } catch (err) { callback({}); } } else { callback({}); } } getProcesses(id, callback) { id = id || ''; if (id) { try { let socket = net.createConnection({ path: socketPath }); let alldata = ''; let data; socket.on('connect', () => { socket.write('GET http:/containers/' + id + '/top?ps_args=-opid,ppid,pgid,vsz,time,etime,nice,ruser,user,rgroup,group,stat,rss,args HTTP/1.0\r\n\r\n'); }); socket.on('data', data => { alldata = alldata + data.toString(); }); socket.on('error', () => { socket = false; callback({}); }); socket.on('end', () => { let startbody = alldata.indexOf('\r\n\r\n'); alldata = alldata.substring(startbody + 4); socket = false; try { data = JSON.parse(alldata); callback(data); } catch (err) { callback({}); } }); } catch (err) { callback({}); } } else { callback({}); } } listVolumes(callback) { try { let socket = net.createConnection({ path: socketPath }); let alldata = ''; let data; socket.on('connect', () => { socket.write('GET http:/volumes HTTP/1.0\r\n\r\n'); }); socket.on('data', data => { alldata = alldata + data.toString(); }); socket.on('error', () => { socket = false; callback({}); }); socket.on('end', () => { let startbody = alldata.indexOf('\r\n\r\n'); alldata = alldata.substring(startbody + 4); socket = false; try { data = JSON.parse(alldata); callback(data); } catch (err) { callback({}); } }); } catch (err) { callback({}); } } } module.exports = DockerSocket;
Back to File Manager