minor refactor
This commit is contained in:
		
							parent
							
								
									c7cda58cc1
								
							
						
					
					
						commit
						ef5bd3ced2
					
				
							
								
								
									
										75
									
								
								README.md
									
									
									
									
									
								
							
							
						
						
									
										75
									
								
								README.md
									
									
									
									
									
								
							| @ -1,10 +1,77 @@ | |||||||
| # [acme-dns-01-vultr](https://git.rootprojects.org/root/acme-dns-01-vultr) | a [Root](https://rootrpojects.org) project | # [acme-dns-01-vultr](https://git.rootprojects.org/root/acme-dns-01-vultr.js) | a [Root](https://rootrpojects.org) project | ||||||
| 
 | 
 | ||||||
| Vultr DNS for Let's Encrypt / ACME dns-01 challenges with ACME.js and Greenlock.js (Node.js). | Vultr DNS + Let's Encrypt for Node.js | ||||||
|  | 
 | ||||||
|  | This handles ACME dns-01 challenges, compatible with ACME.js and Greenlock.js. | ||||||
|  | Passes [acme-dns-01-test](https://git.rootprojects.org/root/acme-dns-01-test.js). | ||||||
|  | 
 | ||||||
|  | # Install | ||||||
|  | 
 | ||||||
|  | ```bash | ||||||
|  | npm install --save acme-dns-01-vultr@3.x | ||||||
|  | ``` | ||||||
|  | 
 | ||||||
|  | # Usage | ||||||
|  | 
 | ||||||
|  | First you create an instance with your credentials: | ||||||
|  | 
 | ||||||
|  | ```js | ||||||
|  | var dns01 = require('acme-dns-01-vultr').create({ | ||||||
|  | 	baseUrl: 'https://api.vultr.com/v1/dns', // default | ||||||
|  | 	apiKey: 'xxxx' | ||||||
|  | }); | ||||||
|  | ``` | ||||||
|  | 
 | ||||||
|  | Then you can use it with any compatible ACME module, | ||||||
|  | such as Greenlock.js or ACME.js. | ||||||
|  | 
 | ||||||
|  | ### Greenlock.js | ||||||
|  | 
 | ||||||
|  | ```js | ||||||
|  | var Greenlock = require('greenlock-express'); | ||||||
|  | var greenlock = Greenlock.create({ | ||||||
|  | 	challenges: { | ||||||
|  | 		'dns-01': dns01 | ||||||
|  | 		// ... | ||||||
|  | 	} | ||||||
|  | }); | ||||||
|  | ``` | ||||||
|  | 
 | ||||||
|  | See [Greenlock™ Express](https://git.rootprojects.org/root/greenlock-express.js) | ||||||
|  | and/or [Greenlock.js](https://git.rootprojects.org/root/greenlock.js) documentation for more details. | ||||||
|  | 
 | ||||||
|  | ### ACME.js | ||||||
|  | 
 | ||||||
|  | ```js | ||||||
|  | // TODO | ||||||
|  | ``` | ||||||
|  | 
 | ||||||
|  | See the [ACME.js](https://git.rootprojects.org/root/acme-v2.js) for more details. | ||||||
|  | 
 | ||||||
|  | ### Build your own | ||||||
|  | 
 | ||||||
|  | ```js | ||||||
|  | dns01 | ||||||
|  |   .set({ | ||||||
|  |     identifier: { value: 'foo.example.com' }, | ||||||
|  |     wildcard: false, | ||||||
|  |     dnsHost: '_acme-challenge.foo.example.com' | ||||||
|  |     dnsAuthorization: 'xxx_secret_xxx' | ||||||
|  |   }) | ||||||
|  |   .then(function () { | ||||||
|  |     console.log("TXT record set"); | ||||||
|  |   }) | ||||||
|  |   .catch(function () { | ||||||
|  |     console.log("Failed to set TXT record"); | ||||||
|  |   }); | ||||||
|  | ``` | ||||||
|  | 
 | ||||||
|  | See [acme-dns-01-test](https://git.rootprojects.org/root/acme-dns-01-test.js) | ||||||
|  | for more implementation details. | ||||||
| 
 | 
 | ||||||
| # Tests | # Tests | ||||||
| 
 | 
 | ||||||
| ``` | ```bash | ||||||
| # node ./test.js domain-zone api-token | # node ./test.js domain-zone api-key | ||||||
| node ./test.js example.com xxxxxx | node ./test.js example.com xxxxxx | ||||||
| ``` | ``` | ||||||
|  | |||||||
							
								
								
									
										148
									
								
								lib/index.js
									
									
									
									
									
								
							
							
						
						
									
										148
									
								
								lib/index.js
									
									
									
									
									
								
							| @ -4,146 +4,118 @@ var request = require('@root/request'); | |||||||
| request = require('util').promisify(request); | request = require('util').promisify(request); | ||||||
| 
 | 
 | ||||||
| var defaults = { | var defaults = { | ||||||
| 	baseUrl: 'https://api.vultr.com/' | 	baseUrl: 'https://api.vultr.com/v1/dns' | ||||||
| }; | }; | ||||||
| 
 | 
 | ||||||
| module.exports.create = function(config) { | module.exports.create = function(config) { | ||||||
| 	var baseUrl = config.baseUrl || defaults.baseUrl; | 	var baseUrl = (config.baseUrl || defaults.baseUrl).replace(/\/$/, ''); | ||||||
| 	var apiKey = config.apiKey; | 	var apiKey = config.apiKey; | ||||||
|  | 
 | ||||||
|  | 	function api(method, path, form) { | ||||||
|  | 		return request({ | ||||||
|  | 			method: method, | ||||||
|  | 			url: baseUrl + path, | ||||||
|  | 			headers: { | ||||||
|  | 				'API-Key': apiKey | ||||||
|  | 			}, | ||||||
|  | 			json: true, | ||||||
|  | 			form: form | ||||||
|  | 		}); | ||||||
|  | 	} | ||||||
|  | 
 | ||||||
| 	return { | 	return { | ||||||
| 		zones: function(data) { | 		zones: function(data) { | ||||||
| 			var url = baseUrl + 'v1/dns/list'; | 			return api('GET', '/list').then(function(resp) { | ||||||
| 			return request({ | 				if (200 !== resp.statusCode) { | ||||||
| 				method: 'GET', |  | ||||||
| 				url: url, |  | ||||||
| 				headers: { |  | ||||||
| 					'API-Key': apiKey |  | ||||||
| 				}, |  | ||||||
| 				json: true |  | ||||||
| 			}).then(function(resp) { |  | ||||||
| 				if (resp.statusCode == 200) { |  | ||||||
| 					return resp.body.map(function(x) { |  | ||||||
| 						return x.domain; |  | ||||||
| 					}); |  | ||||||
| 				} else { |  | ||||||
| 					console.error(resp.statusCode); | 					console.error(resp.statusCode); | ||||||
| 					console.error(resp.body); | 					console.error(resp.body); | ||||||
| 					throw new Error('Could not get list of zones. Check api key, etc'); | 					throw new Error('Could not get list of zones. Check api key, etc'); | ||||||
| 				} | 				} | ||||||
|  | 
 | ||||||
|  | 				return resp.body.map(function(x) { | ||||||
|  | 					return x.domain; | ||||||
|  | 				}); | ||||||
| 			}); | 			}); | ||||||
| 		}, | 		}, | ||||||
| 		set: function(data) { | 		set: function(data) { | ||||||
| 			var ch = data.challenge; | 			var ch = data.challenge; | ||||||
| 			var txt = ch.dnsAuthorization; | 			var txt = ch.dnsAuthorization; | ||||||
| 			// If the domain to be verified is
 | 			// If the domain to be verified is
 | ||||||
| 			var url = baseUrl + 'v1/dns/create_record'; |  | ||||||
| 
 | 
 | ||||||
| 			//console.debug('adding txt', data);
 | 			//console.debug('adding txt', data);
 | ||||||
| 			return request({ | 			return api('POST', '/create_record', { | ||||||
| 				method: 'POST', | 				type: 'TXT', | ||||||
| 				url: url, | 				name: ch.dnsPrefix, | ||||||
| 				headers: { | 				data: '"' + txt + '"', // vultr requires the TXT record wraped in quotes
 | ||||||
| 					'API-Key': apiKey | 				domain: ch.dnsZone, | ||||||
| 				}, | 				ttl: 300 | ||||||
| 				form: { |  | ||||||
| 					type: 'TXT', |  | ||||||
| 					name: ch.dnsPrefix, |  | ||||||
| 					data: '"' + txt + '"', // vultr requires the TXT record wraped in quotes
 |  | ||||||
| 					domain: ch.dnsZone, |  | ||||||
| 					ttl: 300 |  | ||||||
| 				} |  | ||||||
| 			}).then(function(resp) { | 			}).then(function(resp) { | ||||||
| 				if (resp.statusCode == 200) { | 				if (200 !== resp.statusCode) { | ||||||
| 					return true; |  | ||||||
| 				} else { |  | ||||||
| 					console.error(resp.statusCode); | 					console.error(resp.statusCode); | ||||||
| 					console.error(resp.body); | 					console.error(resp.body); | ||||||
| 					throw new Error('record did not set. check subdomain, api key, etc'); | 					throw new Error('record did not set. check subdomain, api key, etc'); | ||||||
| 				} | 				} | ||||||
|  | 
 | ||||||
|  | 				return true; | ||||||
| 			}); | 			}); | ||||||
| 		}, | 		}, | ||||||
| 		remove: function(data) { | 		remove: function(data) { | ||||||
| 			var ch = data.challenge; | 			var ch = data.challenge; | ||||||
| 			var url = baseUrl + 'v1/dns/records'; |  | ||||||
| 
 | 
 | ||||||
| 			return request({ | 			return api('GET', '/records?domain=' + ch.dnsZone) | ||||||
| 				method: 'GET', |  | ||||||
| 				url: url + '?domain=' + ch.dnsZone, |  | ||||||
| 				json: true, |  | ||||||
| 				headers: { |  | ||||||
| 					'API-Key': apiKey |  | ||||||
| 				} |  | ||||||
| 			}) |  | ||||||
| 				.then(function(resp) { | 				.then(function(resp) { | ||||||
| 					if (resp.statusCode == 200) { | 					if (200 !== resp.statusCode) { | ||||||
| 						resp = resp.body; |  | ||||||
| 						//console.debug(resp);
 |  | ||||||
| 						var entries = resp.filter(function(x) { |  | ||||||
| 							return x.type === 'TXT'; |  | ||||||
| 						}); |  | ||||||
| 
 |  | ||||||
| 						var entry = entries.filter(function(x) { |  | ||||||
| 							// vultr wraps the TXT record in double quotes
 |  | ||||||
| 							return ( |  | ||||||
| 								x.data.substring(1, x.data.length - 1) === ch.dnsAuthorization |  | ||||||
| 							); |  | ||||||
| 						})[0]; |  | ||||||
| 
 |  | ||||||
| 						if (entry) { |  | ||||||
| 							return entry['RECORDID']; |  | ||||||
| 						} else { |  | ||||||
| 							throw new Error( |  | ||||||
| 								"Couldn't remove record. check subdomain, api key, etc" |  | ||||||
| 							); |  | ||||||
| 						} |  | ||||||
| 					} else { |  | ||||||
| 						throw new Error( | 						throw new Error( | ||||||
| 							'record did not set. check subdomain, api key, etc' | 							'record did not set. check subdomain, api key, etc' | ||||||
| 						); | 						); | ||||||
| 					} | 					} | ||||||
|  | 
 | ||||||
|  | 					resp = resp.body; | ||||||
|  | 					//console.debug(resp);
 | ||||||
|  | 					var entries = resp.filter(function(x) { | ||||||
|  | 						return x.type === 'TXT'; | ||||||
|  | 					}); | ||||||
|  | 
 | ||||||
|  | 					var entry = entries.filter(function(x) { | ||||||
|  | 						// vultr wraps the TXT record in double quotes
 | ||||||
|  | 						return ( | ||||||
|  | 							x.data.substring(1, x.data.length - 1) === ch.dnsAuthorization | ||||||
|  | 						); | ||||||
|  | 					})[0]; | ||||||
|  | 
 | ||||||
|  | 					if (entry) { | ||||||
|  | 						return entry.RECORDID; | ||||||
|  | 					} else { | ||||||
|  | 						throw new Error( | ||||||
|  | 							"Couldn't remove record. check subdomain, api key, etc" | ||||||
|  | 						); | ||||||
|  | 					} | ||||||
| 				}) | 				}) | ||||||
| 				.then(function(recordId) { | 				.then(function(recordId) { | ||||||
| 					var url = baseUrl + 'v1/dns/delete_record'; | 					return api('POST', '/delete_record', { | ||||||
| 
 | 						domain: ch.dnsZone, | ||||||
| 					return request({ | 						RECORDID: recordId | ||||||
| 						method: 'POST', |  | ||||||
| 						url: url, |  | ||||||
| 						headers: { |  | ||||||
| 							'API-Key': apiKey |  | ||||||
| 						}, |  | ||||||
| 						form: { |  | ||||||
| 							domain: ch.dnsZone, |  | ||||||
| 							RECORDID: recordId |  | ||||||
| 						} |  | ||||||
| 					}).then(function(resp) { | 					}).then(function(resp) { | ||||||
| 						if (resp.statusCode == 200) { | 						if (200 !== resp.statusCode) { | ||||||
| 							return true; |  | ||||||
| 						} else { |  | ||||||
| 							console.error(resp.statusCode); | 							console.error(resp.statusCode); | ||||||
| 							console.error(resp.body); | 							console.error(resp.body); | ||||||
| 							throw new Error( | 							throw new Error( | ||||||
| 								'record did not remove. check subdomain, api key, etc' | 								'record did not remove. check subdomain, api key, etc' | ||||||
| 							); | 							); | ||||||
| 						} | 						} | ||||||
|  | 
 | ||||||
|  | 						return true; | ||||||
| 					}); | 					}); | ||||||
| 				}); | 				}); | ||||||
| 		}, | 		}, | ||||||
| 		get: function(data) { | 		get: function(data) { | ||||||
| 			var ch = data.challenge; | 			var ch = data.challenge; | ||||||
| 			var url = baseUrl + 'v1/dns/records'; |  | ||||||
| 			//console.debug('getting txt', data);
 | 			//console.debug('getting txt', data);
 | ||||||
| 
 | 
 | ||||||
| 			// Digital ocean provides the api to fetch records by ID. Since we do not have id, we fetch all the records,
 | 			// Digital ocean provides the api to fetch records by ID. Since we do not have id, we fetch all the records,
 | ||||||
| 			// filter the required TXT record
 | 			// filter the required TXT record
 | ||||||
| 
 | 
 | ||||||
| 			return request({ | 			return api('GET', '/records?domain=' + ch.dnsZone).then(function(resp) { | ||||||
| 				method: 'GET', |  | ||||||
| 				url: url + '?domain=' + ch.dnsZone, |  | ||||||
| 				json: true, |  | ||||||
| 				headers: { |  | ||||||
| 					'API-Key': apiKey |  | ||||||
| 				} |  | ||||||
| 			}).then(function(resp) { |  | ||||||
| 				resp = resp.body; | 				resp = resp.body; | ||||||
| 
 | 
 | ||||||
| 				var entries = resp.filter(function(x) { | 				var entries = resp.filter(function(x) { | ||||||
|  | |||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user