NodeObserver.php 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. <?php
  2. namespace App\Observers;
  3. use App\Components\DDNS;
  4. use App\Jobs\VNet\reloadNode;
  5. use App\Models\Node;
  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. if ($node->ip) {
  22. foreach ($node->ips() as $ip) {
  23. DDNS::store($node->server, $ip);
  24. }
  25. }
  26. if ($node->ipv6) {
  27. foreach ($node->ips(6) as $ip) {
  28. DDNS::store($node->server, $ip, 'AAAA');
  29. }
  30. }
  31. }
  32. }
  33. public function updated(Node $node): void
  34. {
  35. if ($node->is_ddns === '0' && sysConfig('ddns_mode')) {
  36. $changes = $node->getChanges();
  37. if (Arr::hasAny($changes, ['ip', 'ipv6', 'server'])) { // DDNS操作
  38. if (Arr::exists($changes, 'server')) { // 域名变动
  39. if ($node->getOriginal('server')) {
  40. DDNS::destroy($node->getOriginal('server')); // 删除原域名
  41. }
  42. if ($node->ip) { // 添加IPV4至新域名
  43. foreach ($node->ips() as $ip) {
  44. DDNS::store($node->server, $ip);
  45. }
  46. }
  47. if ($node->ipv6) { // 添加IPV6至新域名
  48. foreach ($node->ips(6) as $ip) {
  49. DDNS::store($node->server, $ip, 'AAAA');
  50. }
  51. }
  52. } else { // 域名未改动
  53. if (Arr::exists($changes, 'ip')) { // IPV4变动
  54. DDNS::destroy($node->server, 'A');
  55. if ($node->ip) { // 非空值 重新设置IPV4
  56. foreach ($node->ips() as $ip) {
  57. DDNS::store($node->server, $ip);
  58. }
  59. }
  60. }
  61. if (Arr::exists($changes, 'ipv6')) { // IPV6变动
  62. DDNS::destroy($node->server, 'AAAA');
  63. if ($node->ipv6) { // 非空值 重新设置IPV6
  64. foreach ($node->ips(6) as $ip) {
  65. DDNS::store($node->server, $ip, 'AAAA');
  66. }
  67. }
  68. }
  69. }
  70. }
  71. }
  72. if ($node->type === '4') {
  73. reloadNode::dispatch($node);
  74. }
  75. }
  76. public function deleted(Node $node): void
  77. {
  78. if ($node->server && sysConfig('ddns_mode')) {
  79. DDNS::destroy($node->server);
  80. }
  81. }
  82. }