Merge pull request #142 from DevoInc/fix/PAR_12954

(fix) Some events are not sent completely

Author: JuanFranDevo

CHANGELOG.md

@@ -4,6 +4,11 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
+## [3.6.1] - 2022-05-19
+### Fixed
+ * Some events are not sent completely due to the use of `socket.send()` instead of `socket.sendall()` [#141]
+
+
 ## [3.6.1] - 2022-05-19
 ### Fixed
  * Dependencies added to `setup.py`

README.md

@@ -1,7 +1,7 @@
 
 [![master Build Status](https://travis-ci.com/DevoInc/python-sdk.svg?branch=master)](https://travis-ci.com/DevoInc/python-sdk) [![LICENSE](https://img.shields.io/dub/l/vibe-d.svg)](https://github.com/DevoInc/python-sdk/blob/master/LICENSE)
 
-[![wheel](https://img.shields.io/badge/wheel-yes-brightgreen.svg)](https://pypi.org/project/devo-sdk/) [![version](https://img.shields.io/badge/version-3.6.1-blue.svg)](https://pypi.org/project/devo-sdk/) [![python](https://img.shields.io/badge/python-3.5%20%7C%203.6%20%7C%203.7%20%7C%203.8%20%7C%203.9-blue.svg)](https://pypi.org/project/devo-sdk/)
+[![wheel](https://img.shields.io/badge/wheel-yes-brightgreen.svg)](https://pypi.org/project/devo-sdk/) [![version](https://img.shields.io/badge/version-3.6.2-blue.svg)](https://pypi.org/project/devo-sdk/) [![python](https://img.shields.io/badge/python-3.5%20%7C%203.6%20%7C%203.7%20%7C%203.8%20%7C%203.9-blue.svg)](https://pypi.org/project/devo-sdk/)
 
 
 # Devo Python SDK
@@ -83,7 +83,7 @@ To perform a request with API, first choose the required endpoint depending on t
 | Europe 	| https://apiv2-eu.devo.com/search/query 	|
 | VDC    	| https://apiv2-es.devo.com/search/query 	|
 
-You have more information in the official documentation of Devo, [REST API](https://docs.devo.com/confluence/ndt/api-reference/rest-api) .
+You have more information in the official documentation of Devo, [REST API](https://docs.devo.com/confluence/ndt/latest/api-reference/query-api) .
 
 ## Credentials
 To obtain the access credentials necessary to use this SDK, you must have an account in [DEVO](https://www.devo.com/).<br/>

devo/__version__.py

@@ -1,6 +1,6 @@
 __description__ = 'Devo Python Library.'
 __url__ = 'http://www.devo.com'
-__version__ = "3.6.1"
+__version__ = "3.6.2"
 __author__ = 'Devo'
 __author_email__ = 'support@devo.com'
 __license__ = 'MIT'

devo/sender/data.py

@@ -551,9 +551,11 @@ def __send_oc(self, record):
         if msg_size % 4096 > 0:
             total += 1
         for iteration in range(0, total):
-            sent += self.socket.send(
-                record[int(iteration * 4096):
-                       int((iteration + 1) * 4096)])
+            part = record[int(iteration * 4096):
+                          int((iteration + 1) * 4096)]
+            if self.socket.sendall(part) is not None:
+                raise DevoSenderException("Send error")
+            sent += len(part)
         if sent == 0:
             raise DevoSenderException("Send error")
         return sent
@@ -573,7 +575,10 @@ def send_raw(self, record, multiline=False, zip=False):
             if self.socket:
                 try:
                     if not multiline and not zip:
-                        sent = self.socket.send(self.__encode_record(record))
+                        msg = self.__encode_record(record)
+                        sent = len(msg)
+                        if self.socket.sendall(msg) is not None:
+                            raise DevoSenderException("Send error")
                         return 1
                     if multiline:
                         record = self.__encode_multiline(record)