NodeObserver.php 2.7 KB

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