fix: update webhook endpoints to api.nfse.io/v2

lib/NFe/APIResource.php

@@ -23,7 +23,7 @@ public static function objectBaseURI() {
       case 'service_invoice':
         return 'serviceInvoices';
       case 'webhook':
-        return 'hooks';
+        return 'webhooks';
       default:
        return $object_type . 's';
     }

lib/NFe/Webhook.php

@@ -1,27 +1,128 @@
 <?php
 
 class NFe_Webhook extends NFe_APIResource {
+
+  /**
+   * Webhook API base URL (api.nfse.io/v2).
+   * Webhooks use a different API host and version than other resources.
+   */
+  private static $webhookBaseURI = 'https://api.nfse.io/v2';
+
+  /**
+   * Response wrapper key used by the v2 API.
+   * The v2 API returns {"webHook": {...}} (camelCase, singular).
+   */
+  private static $responseKey = 'webHook';
+
+  /**
+   * Override the endpoint to use api.nfse.io/v2/webhooks instead of api.nfe.io/v1/hooks.
+   *
+   * @param mixed  $object   Webhook ID (string) or null
+   * @param string $uri_path Not used for webhooks
+   * @return string The full endpoint URL
+   */
+  public static function endpointAPI( $object = null, $uri_path = '' ) {
+    $path = '';
+
+    if ( is_string($object) || is_integer($object) ) {
+      $path = '/' . $object;
+    }
+
+    if ( is_array($object) && isset($object['id']) ) {
+      $path = '/' . $object['id'];
+    }
+
+    return strtolower( self::$webhookBaseURI . '/' . self::objectBaseURI() . $path );
+  }
+
+  /**
+   * Extract webhook data from v2 API response.
+   * The v2 API wraps data in {"webHook": {...}} instead of {"webhooks": {...}}.
+   *
+   * @param object $response Raw API response
+   * @return object The webhook data object
+   */
+  private static function extractFromResponse( $response ) {
+    $key = self::$responseKey;
+    if ( is_object($response) && isset($response->$key) ) {
+      return $response->$key;
+    }
+    return $response;
+  }
+
   public static function create( $attributes = array() ) {
-    return self::createAPI($attributes);
+    $response = self::API()->request( 'POST', self::endpointAPI( $attributes ), $attributes );
+    return self::createFromResponse( self::extractFromResponse($response) );
   }
 
-  public static function fetch( $key ) { 
-  	return self::fetchAPI($key); 
+  public static function fetch( $key ) {
+    try {
+      $response = self::API()->request( 'GET', static::endpointAPI($key) );
+      return self::createFromResponse( self::extractFromResponse($response) );
+    }
+    catch ( NFeObjectNotFound $e ) {
+      throw new NFeObjectNotFound( self::convertClassToObjectType() . ': não encontrado.');
+    }
   }
 
-  public function save() { 
-  	return $this->saveAPI(); 
+  public static function search( $options = array() ) {
+    try {
+      $response = self::API()->request( 'GET', static::endpointAPI($options), $options );
+      return self::createFromResponse( self::extractFromResponse($response) );
+    }
+    catch (Exception $e) {}
+    return array();
   }
 
-  public function delete() { 
-  	return $this->deleteAPI(); 
+  public function save() {
+    try {
+      $response = self::API()->request( $this->is_new() ? 'POST' : 'PUT', static::endpointAPI($this), $this->getAttributes() );
+      $new_object = self::createFromResponse( self::extractFromResponse($response) );
+
+      $this->copy( $new_object );
+      $this->resetStates();
+
+      if ( isset($response->errors) ) {
+        throw new NFeException();
+      }
+    }
+    catch (Exception $e) {
+      return false;
+    }
+    return true;
   }
 
-  public function refresh() { 
-  	return $this->refreshAPI(); 
+  public function delete() {
+    try {
+      $response = self::API()->request( 'DELETE', static::endpointAPI($this) );
+      if ( isset($response->errors) ) {
+        throw new NFeException();
+      }
+    }
+    catch (Exception $e) {
+      return false;
+    }
+    return true;
   }
 
-  public static function search( $options = array() ) { 
-  	return self::searchAPI($options); 
+  public function refresh() {
+    if ( $this->is_new() ) {
+      return false;
+    }
+
+    try {
+      $response = self::API()->request( 'GET', static::endpointAPI($this) );
+      if ( isset($response->errors) ) {
+        throw new NFeObjectNotFound();
+      }
+
+      $new_object = self::createFromResponse( self::extractFromResponse($response) );
+      $this->copy( $new_object );
+      $this->resetStates();
+    }
+    catch (Exception $e) {
+      return false;
+    }
+    return true;
   }
 }

test/NFe/WebhookTest.php

@@ -16,44 +16,43 @@ public function testCreateAndDelete() {
     $object = NFe_Webhook::create( $attributes );
 
     $this->assertNotNull($object);
-    $this->assertNotNull($object->hooks->url);
-    $this->assertEqual($object->hooks->url, $attributes['url']);
+    $this->assertNotNull($object->uri);
+    $this->assertEqual($object->uri, $attributes['url']);
 
-    self::$id = $object->hooks->id;
+    self::$id = $object->id;
   }
 
   public function testGet() {
     $object = NFe_Webhook::fetch( self::$id );
 
     $this->assertNotNull( $object );
-    $this->assertNotNull( $object['hooks'][0]->url );
-    $this->assertEqual( $object['hooks'][0]->url, 'http://google.com/test' );
+    $this->assertNotNull( $object->uri );
+    $this->assertEqual( $object->uri, 'http://google.com/test' );
   }
 
   public function testUpdate() {
     $object = NFe_Webhook::fetch( self::$id );
 
     $new_url = 'http://google.com/test2';
-    $object->hooks->url = $new_url;
+    $object->uri = $new_url;
 
     $this->assertTrue($object->save());
     $this->assertNotNull($object);
-    $this->assertNotNull($object->hooks->url);
-    $this->assertEqual($object->hooks->url, $new_url);
+    $this->assertNotNull($object->uri);
+    $this->assertEqual($object->uri, $new_url);
   }
 
   public function testDelete() {
     $object = NFe_Webhook::fetch( self::$id );
 
     $this->assertNotNull($object);
-    $this->assertNotNull( $object->hooks->url );
+    $this->assertNotNull( $object->uri );
     $this->assertTrue($object->delete());
   }
 
   public function testSearch() {
     $hooks = NFe_Webhook::search();
 
     $this->assertNotNull( $hooks );
-    $this->assertNotNull( $hooks->hooks );
   }
 }