Implement storing binary serialized operations in the HAF database

Related issue: #92 (closed)

Merge Request related to this one on the hive-side: hive!802 (merged)

Changes to the repo:

• Fixed hive_fork_manager being built always in the mainnet configuration on the CI
• Added new type: hive.operation
• Added operator class (using btree) for the hive.operation type
• Changed hive.operations.body column type from text to hive.operation
• Made CUSTOM_LOG variadic arguments optional
• Optimized escape_raw function
• Changed tests to work with the new type
• Made colect_data_and_fill_returned_recordset truly noexcept
• Created colect_operation_data_and_fill_returned_recordset function wrapping colect_data_and_fill_returned_recordset function specifically for the hive.operation type
• Changed sql_serializer to put binary data into the hive.operations table instead of the json representation
• Added HiveOperation type class for the sqlalchemy ORM

What should be added/changed/discussed before merging (not critical):

• Fix warnings generated by the sqlalchemy ORM related to the hive.operation type
• Make update_state_provider_keyauth function work with the binary data representation instead of text one
• Search for other possibilities to optimize the SQL code execution using binary data representation instead of the text one

@gandalf Please review and test full replay + live sync

src/hive_fork_manager/shared_lib/operation_base.cpp

@@ -72,6 +72,8 @@ std::vector< char > json_to_op( const char* raw_data )
 
 extern "C"
 {
+#include <utils/hashutils.h>
+
   PG_MODULE_MAGIC;
 
   _operation* make_operation( const char* raw_data, uint32 data_length )
@@ -84,10 +86,14 @@ extern "C"
     return op;
   }
 
-  bool operation_equal( const _operation* lhs, const _operation* rhs )
+  int operation_cmp_impl( const _operation* lhs, const _operation* rhs )
   {
-    return VarSizeEqual( lhs->data, rhs->data ) ? memcmp( VARDATA_ANY( lhs->data ), VARDATA_ANY( rhs->data ), VARSIZE_ANY_EXHDR( lhs->data ) ) == 0
-                                                : false;
+    if( VARSIZE_ANY_EXHDR( lhs ) > VARSIZE_ANY_EXHDR( rhs ) )
+      return 1;
+    else if( VARSIZE_ANY_EXHDR( lhs ) < VARSIZE_ANY_EXHDR( rhs ) )
+      return -1;
+
+    return memcmp( VARDATA_ANY( lhs ), VARDATA_ANY( rhs ), VARSIZE_ANY_EXHDR( lhs ) );
   }
 
   Datum operation_in( PG_FUNCTION_ARGS )
@@ -150,7 +156,7 @@ extern "C"
     _operation* lhs = PG_GETARG_HIVE_OPERATION_PP( 0 );
     _operation* rhs = PG_GETARG_HIVE_OPERATION_PP( 1 );
 
-    PG_RETURN_BOOL( operation_equal( lhs, rhs ) );
+    PG_RETURN_BOOL( operation_cmp_impl( lhs, rhs ) == 0 );
   }
 
   Datum operation_ne( PG_FUNCTION_ARGS )
@@ -158,6 +164,57 @@ extern "C"
     _operation* lhs = PG_GETARG_HIVE_OPERATION_PP( 0 );
     _operation* rhs = PG_GETARG_HIVE_OPERATION_PP( 1 );
 
-    PG_RETURN_BOOL( !operation_equal( lhs, rhs ) );
+    PG_RETURN_BOOL( operation_cmp_impl( lhs, rhs ) != 0 );
+  }
+
+  Datum operation_gt( PG_FUNCTION_ARGS )
+  {
+    _operation* lhs = PG_GETARG_HIVE_OPERATION_PP( 0 );
+    _operation* rhs = PG_GETARG_HIVE_OPERATION_PP( 1 );
+
+    PG_RETURN_BOOL( operation_cmp_impl( lhs, rhs ) > 0 );
+  }
+
+  Datum operation_ge( PG_FUNCTION_ARGS )
+  {
+    _operation* lhs = PG_GETARG_HIVE_OPERATION_PP( 0 );
+    _operation* rhs = PG_GETARG_HIVE_OPERATION_PP( 1 );
+
+    PG_RETURN_BOOL( operation_cmp_impl( lhs, rhs ) >= 0 );
+  }
+
+  Datum operation_lt( PG_FUNCTION_ARGS )
+  {
+    _operation* lhs = PG_GETARG_HIVE_OPERATION_PP( 0 );
+    _operation* rhs = PG_GETARG_HIVE_OPERATION_PP( 1 );
+
+    PG_RETURN_BOOL( operation_cmp_impl( lhs, rhs ) < 0 );
+  }
+
+  Datum operation_le( PG_FUNCTION_ARGS )
+  {
+    _operation* lhs = PG_GETARG_HIVE_OPERATION_PP( 0 );
+    _operation* rhs = PG_GETARG_HIVE_OPERATION_PP( 1 );
+
+    PG_RETURN_BOOL( operation_cmp_impl( lhs, rhs ) <= 0 );
+  }
+
+  Datum operation_cmp( PG_FUNCTION_ARGS )
+  {
+    _operation* lhs = PG_GETARG_HIVE_OPERATION_PP( 0 );
+    _operation* rhs = PG_GETARG_HIVE_OPERATION_PP( 1 );
+
+    PG_RETURN_INT32( operation_cmp_impl( lhs, rhs ) );
+  }
+
+  Datum operation_hash( PG_FUNCTION_ARGS )
+  {
+    _operation* lhs = PG_GETARG_HIVE_OPERATION_PP( 0 );
+
+    Datum		result;
+
+    result = hash_any((unsigned char *) VARDATA_ANY( lhs ), VARSIZE_ANY_EXHDR( lhs ));
+
+    PG_RETURN_DATUM( result );
   }
 }