NodeObserver.php 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. <?php
  2. namespace App\Observers;
  3. use App\Components\DDNS;
  4. use App\Jobs\VNet\reloadNode;
  5. use App\Models\Node;
  6. use App\Models\NodeAuth;
  7. use App\Services\NodeService;
  8. use Arr;
  9. use Log;
  10. use Str;
  11. class NodeObserver
  12. {
  13. public function saved(Node $node): void
  14. {
  15. (new NodeService())->getNodeGeo($node->id);
  16. }
  17. public function created(Node $node): void
  18. {
  19. $auth = new NodeAuth();
  20. $auth->node_id = $node->id;
  21. $auth->key = Str::random();
  22. $auth->secret = Str::random(8);
  23. if (! $auth->save()) {
  24. Log::warning('节点生成-自动生成授权时出现错误,请稍后自行生成授权!');
  25. }
  26. if ($node->is_ddns === 0 && $node->server && sysConfig('ddns_mode')) {
  27. if ($node->ip) {
  28. DDNS::store($node->server, $node->ip);
  29. }
  30. if ($node->ipv6) {
  31. DDNS::store($node->server, $node->ipv6, 'AAAA');
  32. }
  33. }
  34. }
  35. public function updated(Node $node): void
  36. {
  37. if ($node->is_ddns == 0 && sysConfig('ddns_mode')) {
  38. $changes = $node->getChanges();
  39. if (Arr::hasAny($changes, ['ip', 'ipv6', 'server'])) {
  40. if (Arr::exists($changes, 'server')) {
  41. DDNS::destroy($node->getOriginal('server'));
  42. if ($node->ip) {
  43. DDNS::store($node->server, $node->ip);
  44. }
  45. if ($node->ipv6) {
  46. DDNS::store($node->server, $node->ipv6, 'AAAA');
  47. }
  48. } else {
  49. if (Arr::exists($changes, 'ip')) {
  50. if ($node->ip && $node->getOriginal('ip')) {
  51. DDNS::update($node->server, $node->ip);
  52. } elseif ($node->ip) {
  53. DDNS::store($node->server, $node->ip);
  54. } else {
  55. DDNS::destroy($node->server, 'A');
  56. }
  57. }
  58. if (Arr::exists($changes, 'ipv6')) {
  59. if ($node->ipv6 && $node->getOriginal('ipv6')) {
  60. DDNS::update($node->server, $node->ipv6, 'AAAA');
  61. } elseif ($node->ipv6) {
  62. DDNS::store($node->server, $node->ipv6, 'AAAA');
  63. } else {
  64. DDNS::destroy($node->server, 'AAAA');
  65. }
  66. }
  67. }
  68. }
  69. }
  70. if ($node->type === 4) {
  71. reloadNode::dispatch($node);
  72. }
  73. }
  74. public function deleted(Node $node): void
  75. {
  76. if ($node->is_ddns === 0 && $node->server && sysConfig('ddns_mode')) {
  77. DDNS::destroy($node->server);
  78. }
  79. }
  80. }