NodeObserver.php 3.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. <?php
  2. namespace App\Observers;
  3. use App\Jobs\VNet\reloadNode;
  4. use App\Models\Node;
  5. use App\Utils\DDNS;
  6. use Arr;
  7. use Log;
  8. use Str;
  9. class NodeObserver
  10. {
  11. public function saved(Node $node): void
  12. {
  13. $node->refresh_geo();
  14. }
  15. public function created(Node $node): void
  16. {
  17. if (! $node->auth()->create(['key' => Str::random(), 'secret' => Str::random(8)])) {
  18. Log::error('节点生成-自动生成授权时出现错误,请稍后自行生成授权!');
  19. }
  20. if ($node->is_ddns === '0' && $node->server && sysConfig('ddns_mode')) {
  21. $newDNS = new DDNS($node->server);
  22. if ($node->ip) {
  23. foreach ($node->ips() as $ip) {
  24. $newDNS->store($ip);
  25. }
  26. }
  27. if ($node->ipv6) {
  28. foreach ($node->ips(6) as $ip) {
  29. $newDNS->store($ip, 'AAAA');
  30. }
  31. }
  32. }
  33. }
  34. public function updated(Node $node): void
  35. {
  36. if ($node->is_ddns === '0' && sysConfig('ddns_mode')) {
  37. $changes = $node->getChanges();
  38. if (Arr::hasAny($changes, ['ip', 'ipv6', 'server'])) {
  39. $newDNS = new DDNS($node->server);
  40. if (Arr::has($changes, 'server')) { // 域名变动
  41. if ($node->getOriginal('server')) {
  42. (new DDNS($node->getOriginal('server')))->destroy(); // 删除原域名
  43. }
  44. if ($node->ip) { // 添加IPV4至新域名
  45. foreach ($node->ips() as $ip) {
  46. $newDNS->store($ip);
  47. }
  48. }
  49. if ($node->ipv6) { // 添加IPV6至新域名
  50. foreach ($node->ips(6) as $ip) {
  51. $newDNS->store($ip, 'AAAA');
  52. }
  53. }
  54. } else {// 域名未改动
  55. if (Arr::has($changes, 'ip')) { // IPV4变动
  56. $newDNS->destroy('A');
  57. if ($node->ip) { // 非空值 重新设置IPV4
  58. foreach ($node->ips() as $ip) {
  59. $newDNS->store($ip);
  60. }
  61. }
  62. }
  63. if (Arr::has($changes, 'ipv6')) { // IPV6变动
  64. $newDNS->destroy('AAAA');
  65. if ($node->ipv6) { // 非空值 重新设置IPV6
  66. foreach ($node->ips(6) as $ip) {
  67. $newDNS->store($ip, 'AAAA');
  68. }
  69. }
  70. }
  71. }
  72. }
  73. }
  74. if ($node->type === '4') {
  75. reloadNode::dispatch($node);
  76. }
  77. }
  78. public function deleted(Node $node): void
  79. {
  80. if ($node->server && sysConfig('ddns_mode')) {
  81. (new DDNS($node->server))->destroy();
  82. }
  83. }
  84. }