Convert SelectUrl definition to accept url overrides from config

Add automatic versioning to Connected.ServiceModel.Client.Storage

.editorconfig

@@ -0,0 +1,226 @@
+# Remove the line below if you want to inherit .editorconfig settings from higher directories
+root = true
+
+# C# files
+[*.cs]
+
+#### Core EditorConfig Options ####
+
+# Indentation and spacing
+indent_size = 4
+indent_style = tab
+tab_width = 4
+
+# New line preferences
+end_of_line = crlf
+insert_final_newline = false
+
+#### .NET Coding Conventions ####
+
+# Organize usings
+dotnet_separate_import_directive_groups = false
+dotnet_sort_system_directives_first = true
+file_header_template = unset
+
+# this. and Me. preferences
+dotnet_style_qualification_for_event = false
+dotnet_style_qualification_for_field = false
+dotnet_style_qualification_for_method = false
+dotnet_style_qualification_for_property = false
+
+# Language keywords vs BCL types preferences
+dotnet_style_predefined_type_for_locals_parameters_members = true
+dotnet_style_predefined_type_for_member_access = true
+
+# Parentheses preferences
+dotnet_style_parentheses_in_arithmetic_binary_operators = always_for_clarity
+dotnet_style_parentheses_in_other_binary_operators = always_for_clarity
+dotnet_style_parentheses_in_other_operators = never_if_unnecessary
+dotnet_style_parentheses_in_relational_binary_operators = always_for_clarity
+
+# Modifier preferences
+dotnet_style_require_accessibility_modifiers = for_non_interface_members
+
+# Expression-level preferences
+dotnet_style_coalesce_expression = true
+dotnet_style_collection_initializer = true
+dotnet_style_explicit_tuple_names = true
+dotnet_style_namespace_match_folder = true
+dotnet_style_null_propagation = true
+dotnet_style_object_initializer = true
+dotnet_style_operator_placement_when_wrapping = beginning_of_line
+dotnet_style_prefer_auto_properties = true
+dotnet_style_prefer_compound_assignment = true
+dotnet_style_prefer_conditional_expression_over_assignment = true
+dotnet_style_prefer_conditional_expression_over_return = true
+dotnet_style_prefer_foreach_explicit_cast_in_source = when_strongly_typed
+dotnet_style_prefer_inferred_anonymous_type_member_names = true
+dotnet_style_prefer_inferred_tuple_names = true
+dotnet_style_prefer_is_null_check_over_reference_equality_method = true
+dotnet_style_prefer_simplified_boolean_expressions = true
+dotnet_style_prefer_simplified_interpolation = true
+
+# Field preferences
+dotnet_style_readonly_field = true
+
+# Parameter preferences
+dotnet_code_quality_unused_parameters = all
+
+# Suppression preferences
+dotnet_remove_unnecessary_suppression_exclusions = none
+
+# New line preferences
+dotnet_style_allow_multiple_blank_lines_experimental = false
+dotnet_style_allow_statement_immediately_after_block_experimental = false
+
+#### C# Coding Conventions ####
+
+# var preferences
+csharp_style_var_elsewhere = true
+csharp_style_var_for_built_in_types = true
+csharp_style_var_when_type_is_apparent = true
+
+# Expression-bodied members
+csharp_style_expression_bodied_accessors = true
+csharp_style_expression_bodied_constructors = false
+csharp_style_expression_bodied_indexers = true
+csharp_style_expression_bodied_lambdas = true
+csharp_style_expression_bodied_local_functions = false
+csharp_style_expression_bodied_methods = false
+csharp_style_expression_bodied_operators = false
+csharp_style_expression_bodied_properties = true
+
+# Pattern matching preferences
+csharp_style_pattern_matching_over_as_with_null_check = true
+csharp_style_pattern_matching_over_is_with_cast_check = true
+csharp_style_prefer_extended_property_pattern = true
+csharp_style_prefer_not_pattern = true
+csharp_style_prefer_pattern_matching = true
+csharp_style_prefer_switch_expression = true
+
+# Null-checking preferences
+csharp_style_conditional_delegate_call = true
+
+# Modifier preferences
+csharp_prefer_static_local_function = true
+csharp_preferred_modifier_order = public,private,protected,internal,file,static,extern,new,virtual,abstract,sealed,override,readonly,unsafe,required,volatile,async
+csharp_style_prefer_readonly_struct = true
+
+# Code-block preferences
+csharp_prefer_braces = when_multiline
+csharp_prefer_simple_using_statement = true
+csharp_style_namespace_declarations = file_scoped
+csharp_style_prefer_method_group_conversion = true
+csharp_style_prefer_top_level_statements = true
+
+# Expression-level preferences
+csharp_prefer_simple_default_expression = true
+csharp_style_deconstructed_variable_declaration = true
+csharp_style_implicit_object_creation_when_type_is_apparent = true
+csharp_style_inlined_variable_declaration = true
+csharp_style_prefer_index_operator = true
+csharp_style_prefer_local_over_anonymous_function = true
+csharp_style_prefer_null_check_over_type_check = true
+csharp_style_prefer_range_operator = true
+csharp_style_prefer_tuple_swap = true
+csharp_style_prefer_utf8_string_literals = true
+csharp_style_throw_expression = true
+csharp_style_unused_value_assignment_preference = discard_variable
+csharp_style_unused_value_expression_statement_preference = discard_variable
+
+# 'using' directive preferences
+csharp_using_directive_placement = outside_namespace
+
+# New line preferences
+csharp_style_allow_blank_line_after_colon_in_constructor_initializer_experimental = true
+csharp_style_allow_blank_lines_between_consecutive_braces_experimental = false
+csharp_style_allow_embedded_statements_on_same_line_experimental = false
+
+#### C# Formatting Rules ####
+
+# New line preferences
+csharp_new_line_before_catch = true
+csharp_new_line_before_else = true
+csharp_new_line_before_finally = true
+csharp_new_line_before_members_in_anonymous_types = true
+csharp_new_line_before_members_in_object_initializers = true
+csharp_new_line_before_open_brace = all
+csharp_new_line_between_query_expression_clauses = true
+
+# Indentation preferences
+csharp_indent_block_contents = true
+csharp_indent_braces = false
+csharp_indent_case_contents = true
+csharp_indent_case_contents_when_block = true
+csharp_indent_labels = one_less_than_current
+csharp_indent_switch_labels = true
+
+# Space preferences
+csharp_space_after_cast = false
+csharp_space_after_colon_in_inheritance_clause = true
+csharp_space_after_comma = true
+csharp_space_after_dot = false
+csharp_space_after_keywords_in_control_flow_statements = true
+csharp_space_after_semicolon_in_for_statement = true
+csharp_space_around_binary_operators = before_and_after
+csharp_space_around_declaration_statements = false
+csharp_space_before_colon_in_inheritance_clause = true
+csharp_space_before_comma = false
+csharp_space_before_dot = false
+csharp_space_before_open_square_brackets = false
+csharp_space_before_semicolon_in_for_statement = false
+csharp_space_between_empty_square_brackets = false
+csharp_space_between_method_call_empty_parameter_list_parentheses = false
+csharp_space_between_method_call_name_and_opening_parenthesis = false
+csharp_space_between_method_call_parameter_list_parentheses = false
+csharp_space_between_method_declaration_empty_parameter_list_parentheses = false
+csharp_space_between_method_declaration_name_and_open_parenthesis = false
+csharp_space_between_method_declaration_parameter_list_parentheses = false
+csharp_space_between_parentheses = false
+csharp_space_between_square_brackets = false
+
+# Wrapping preferences
+csharp_preserve_single_line_blocks = true
+csharp_preserve_single_line_statements = false
+
+#### Naming styles ####
+
+# Naming rules
+
+dotnet_naming_rule.interface_should_be_begins_with_i.severity = suggestion
+dotnet_naming_rule.interface_should_be_begins_with_i.symbols = interface
+dotnet_naming_rule.interface_should_be_begins_with_i.style = begins_with_i
+
+dotnet_naming_rule.types_should_be_pascal_case.severity = suggestion
+dotnet_naming_rule.types_should_be_pascal_case.symbols = types
+dotnet_naming_rule.types_should_be_pascal_case.style = pascal_case
+
+dotnet_naming_rule.non_field_members_should_be_pascal_case.severity = suggestion
+dotnet_naming_rule.non_field_members_should_be_pascal_case.symbols = non_field_members
+dotnet_naming_rule.non_field_members_should_be_pascal_case.style = pascal_case
+
+# Symbol specifications
+
+dotnet_naming_symbols.interface.applicable_kinds = interface
+dotnet_naming_symbols.interface.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.interface.required_modifiers = 
+
+dotnet_naming_symbols.types.applicable_kinds = class, struct, interface, enum
+dotnet_naming_symbols.types.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.types.required_modifiers = 
+
+dotnet_naming_symbols.non_field_members.applicable_kinds = property, event, method
+dotnet_naming_symbols.non_field_members.applicable_accessibilities = public, internal, private, protected, protected_internal, private_protected
+dotnet_naming_symbols.non_field_members.required_modifiers = 
+
+# Naming styles
+
+dotnet_naming_style.pascal_case.required_prefix = 
+dotnet_naming_style.pascal_case.required_suffix = 
+dotnet_naming_style.pascal_case.word_separator = 
+dotnet_naming_style.pascal_case.capitalization = pascal_case
+
+dotnet_naming_style.begins_with_i.required_prefix = I
+dotnet_naming_style.begins_with_i.required_suffix = 
+dotnet_naming_style.begins_with_i.word_separator = 
+dotnet_naming_style.begins_with_i.capitalization = pascal_case

Framerwork.ServiceModel.Client.sln

@@ -0,0 +1,37 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.4.33027.239
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Connected.ServiceModel.Client", "src\Connected.ServiceModel.Client\Connected.ServiceModel.Client.csproj", "{679249A7-58C5-42D9-A764-4EBDC7DE7F9D}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Connected.ServiceModel.Client.Storage", "src\Connected.ServiceModel.Client.Storage\Connected.ServiceModel.Client.Storage.csproj", "{1F7F8DB9-3545-4B06-BAB8-3A15611E39EA}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Connected.ServiceModel.Client.Data", "src\Connected.ServiceModel.Client.Data\Connected.ServiceModel.Client.Data.csproj", "{D9F21D24-E114-4901-8245-720A1094EA24}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{679249A7-58C5-42D9-A764-4EBDC7DE7F9D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{679249A7-58C5-42D9-A764-4EBDC7DE7F9D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{679249A7-58C5-42D9-A764-4EBDC7DE7F9D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{679249A7-58C5-42D9-A764-4EBDC7DE7F9D}.Release|Any CPU.Build.0 = Release|Any CPU
+		{1F7F8DB9-3545-4B06-BAB8-3A15611E39EA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{1F7F8DB9-3545-4B06-BAB8-3A15611E39EA}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{1F7F8DB9-3545-4B06-BAB8-3A15611E39EA}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{1F7F8DB9-3545-4B06-BAB8-3A15611E39EA}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D9F21D24-E114-4901-8245-720A1094EA24}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D9F21D24-E114-4901-8245-720A1094EA24}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D9F21D24-E114-4901-8245-720A1094EA24}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D9F21D24-E114-4901-8245-720A1094EA24}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {62DF7178-0DD2-461C-999E-51A5E1BB8CAD}
+	EndGlobalSection
+EndGlobal

LICENSE

@@ -0,0 +1,661 @@
+                    GNU AFFERO GENERAL PUBLIC LICENSE
+                       Version 3, 19 November 2007
+
+ Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
+ Everyone is permitted to copy and distribute verbatim copies
+ of this license document, but changing it is not allowed.
+
+                            Preamble
+
+  The GNU Affero General Public License is a free, copyleft license for
+software and other kinds of works, specifically designed to ensure
+cooperation with the community in the case of network server software.
+
+  The licenses for most software and other practical works are designed
+to take away your freedom to share and change the works.  By contrast,
+our General Public Licenses are intended to guarantee your freedom to
+share and change all versions of a program--to make sure it remains free
+software for all its users.
+
+  When we speak of free software, we are referring to freedom, not
+price.  Our General Public Licenses are designed to make sure that you
+have the freedom to distribute copies of free software (and charge for
+them if you wish), that you receive source code or can get it if you
+want it, that you can change the software or use pieces of it in new
+free programs, and that you know you can do these things.
+
+  Developers that use our General Public Licenses protect your rights
+with two steps: (1) assert copyright on the software, and (2) offer
+you this License which gives you legal permission to copy, distribute
+and/or modify the software.
+
+  A secondary benefit of defending all users' freedom is that
+improvements made in alternate versions of the program, if they
+receive widespread use, become available for other developers to
+incorporate.  Many developers of free software are heartened and
+encouraged by the resulting cooperation.  However, in the case of
+software used on network servers, this result may fail to come about.
+The GNU General Public License permits making a modified version and
+letting the public access it on a server without ever releasing its
+source code to the public.
+
+  The GNU Affero General Public License is designed specifically to
+ensure that, in such cases, the modified source code becomes available
+to the community.  It requires the operator of a network server to
+provide the source code of the modified version running there to the
+users of that server.  Therefore, public use of a modified version, on
+a publicly accessible server, gives the public access to the source
+code of the modified version.
+
+  An older license, called the Affero General Public License and
+published by Affero, was designed to accomplish similar goals.  This is
+a different license, not a version of the Affero GPL, but Affero has
+released a new version of the Affero GPL which permits relicensing under
+this license.
+
+  The precise terms and conditions for copying, distribution and
+modification follow.
+
+                       TERMS AND CONDITIONS
+
+  0. Definitions.
+
+  "This License" refers to version 3 of the GNU Affero General Public License.
+
+  "Copyright" also means copyright-like laws that apply to other kinds of
+works, such as semiconductor masks.
+
+  "The Program" refers to any copyrightable work licensed under this
+License.  Each licensee is addressed as "you".  "Licensees" and
+"recipients" may be individuals or organizations.
+
+  To "modify" a work means to copy from or adapt all or part of the work
+in a fashion requiring copyright permission, other than the making of an
+exact copy.  The resulting work is called a "modified version" of the
+earlier work or a work "based on" the earlier work.
+
+  A "covered work" means either the unmodified Program or a work based
+on the Program.
+
+  To "propagate" a work means to do anything with it that, without
+permission, would make you directly or secondarily liable for
+infringement under applicable copyright law, except executing it on a
+computer or modifying a private copy.  Propagation includes copying,
+distribution (with or without modification), making available to the
+public, and in some countries other activities as well.
+
+  To "convey" a work means any kind of propagation that enables other
+parties to make or receive copies.  Mere interaction with a user through
+a computer network, with no transfer of a copy, is not conveying.
+
+  An interactive user interface displays "Appropriate Legal Notices"
+to the extent that it includes a convenient and prominently visible
+feature that (1) displays an appropriate copyright notice, and (2)
+tells the user that there is no warranty for the work (except to the
+extent that warranties are provided), that licensees may convey the
+work under this License, and how to view a copy of this License.  If
+the interface presents a list of user commands or options, such as a
+menu, a prominent item in the list meets this criterion.
+
+  1. Source Code.
+
+  The "source code" for a work means the preferred form of the work
+for making modifications to it.  "Object code" means any non-source
+form of a work.
+
+  A "Standard Interface" means an interface that either is an official
+standard defined by a recognized standards body, or, in the case of
+interfaces specified for a particular programming language, one that
+is widely used among developers working in that language.
+
+  The "System Libraries" of an executable work include anything, other
+than the work as a whole, that (a) is included in the normal form of
+packaging a Major Component, but which is not part of that Major
+Component, and (b) serves only to enable use of the work with that
+Major Component, or to implement a Standard Interface for which an
+implementation is available to the public in source code form.  A
+"Major Component", in this context, means a major essential component
+(kernel, window system, and so on) of the specific operating system
+(if any) on which the executable work runs, or a compiler used to
+produce the work, or an object code interpreter used to run it.
+
+  The "Corresponding Source" for a work in object code form means all
+the source code needed to generate, install, and (for an executable
+work) run the object code and to modify the work, including scripts to
+control those activities.  However, it does not include the work's
+System Libraries, or general-purpose tools or generally available free
+programs which are used unmodified in performing those activities but
+which are not part of the work.  For example, Corresponding Source
+includes interface definition files associated with source files for
+the work, and the source code for shared libraries and dynamically
+linked subprograms that the work is specifically designed to require,
+such as by intimate data communication or control flow between those
+subprograms and other parts of the work.
+
+  The Corresponding Source need not include anything that users
+can regenerate automatically from other parts of the Corresponding
+Source.
+
+  The Corresponding Source for a work in source code form is that
+same work.
+
+  2. Basic Permissions.
+
+  All rights granted under this License are granted for the term of
+copyright on the Program, and are irrevocable provided the stated
+conditions are met.  This License explicitly affirms your unlimited
+permission to run the unmodified Program.  The output from running a
+covered work is covered by this License only if the output, given its
+content, constitutes a covered work.  This License acknowledges your
+rights of fair use or other equivalent, as provided by copyright law.
+
+  You may make, run and propagate covered works that you do not
+convey, without conditions so long as your license otherwise remains
+in force.  You may convey covered works to others for the sole purpose
+of having them make modifications exclusively for you, or provide you
+with facilities for running those works, provided that you comply with
+the terms of this License in conveying all material for which you do
+not control copyright.  Those thus making or running the covered works
+for you must do so exclusively on your behalf, under your direction
+and control, on terms that prohibit them from making any copies of
+your copyrighted material outside their relationship with you.
+
+  Conveying under any other circumstances is permitted solely under
+the conditions stated below.  Sublicensing is not allowed; section 10
+makes it unnecessary.
+
+  3. Protecting Users' Legal Rights From Anti-Circumvention Law.
+
+  No covered work shall be deemed part of an effective technological
+measure under any applicable law fulfilling obligations under article
+11 of the WIPO copyright treaty adopted on 20 December 1996, or
+similar laws prohibiting or restricting circumvention of such
+measures.
+
+  When you convey a covered work, you waive any legal power to forbid
+circumvention of technological measures to the extent such circumvention
+is effected by exercising rights under this License with respect to
+the covered work, and you disclaim any intention to limit operation or
+modification of the work as a means of enforcing, against the work's
+users, your or third parties' legal rights to forbid circumvention of
+technological measures.
+
+  4. Conveying Verbatim Copies.
+
+  You may convey verbatim copies of the Program's source code as you
+receive it, in any medium, provided that you conspicuously and
+appropriately publish on each copy an appropriate copyright notice;
+keep intact all notices stating that this License and any
+non-permissive terms added in accord with section 7 apply to the code;
+keep intact all notices of the absence of any warranty; and give all
+recipients a copy of this License along with the Program.
+
+  You may charge any price or no price for each copy that you convey,
+and you may offer support or warranty protection for a fee.
+
+  5. Conveying Modified Source Versions.
+
+  You may convey a work based on the Program, or the modifications to
+produce it from the Program, in the form of source code under the
+terms of section 4, provided that you also meet all of these conditions:
+
+    a) The work must carry prominent notices stating that you modified
+    it, and giving a relevant date.
+
+    b) The work must carry prominent notices stating that it is
+    released under this License and any conditions added under section
+    7.  This requirement modifies the requirement in section 4 to
+    "keep intact all notices".
+
+    c) You must license the entire work, as a whole, under this
+    License to anyone who comes into possession of a copy.  This
+    License will therefore apply, along with any applicable section 7
+    additional terms, to the whole of the work, and all its parts,
+    regardless of how they are packaged.  This License gives no
+    permission to license the work in any other way, but it does not
+    invalidate such permission if you have separately received it.
+
+    d) If the work has interactive user interfaces, each must display
+    Appropriate Legal Notices; however, if the Program has interactive
+    interfaces that do not display Appropriate Legal Notices, your
+    work need not make them do so.
+
+  A compilation of a covered work with other separate and independent
+works, which are not by their nature extensions of the covered work,
+and which are not combined with it such as to form a larger program,
+in or on a volume of a storage or distribution medium, is called an
+"aggregate" if the compilation and its resulting copyright are not
+used to limit the access or legal rights of the compilation's users
+beyond what the individual works permit.  Inclusion of a covered work
+in an aggregate does not cause this License to apply to the other
+parts of the aggregate.
+
+  6. Conveying Non-Source Forms.
+
+  You may convey a covered work in object code form under the terms
+of sections 4 and 5, provided that you also convey the
+machine-readable Corresponding Source under the terms of this License,
+in one of these ways:
+
+    a) Convey the object code in, or embodied in, a physical product
+    (including a physical distribution medium), accompanied by the
+    Corresponding Source fixed on a durable physical medium
+    customarily used for software interchange.
+
+    b) Convey the object code in, or embodied in, a physical product
+    (including a physical distribution medium), accompanied by a
+    written offer, valid for at least three years and valid for as
+    long as you offer spare parts or customer support for that product
+    model, to give anyone who possesses the object code either (1) a
+    copy of the Corresponding Source for all the software in the
+    product that is covered by this License, on a durable physical
+    medium customarily used for software interchange, for a price no
+    more than your reasonable cost of physically performing this
+    conveying of source, or (2) access to copy the
+    Corresponding Source from a network server at no charge.
+
+    c) Convey individual copies of the object code with a copy of the
+    written offer to provide the Corresponding Source.  This
+    alternative is allowed only occasionally and noncommercially, and
+    only if you received the object code with such an offer, in accord
+    with subsection 6b.
+
+    d) Convey the object code by offering access from a designated
+    place (gratis or for a charge), and offer equivalent access to the
+    Corresponding Source in the same way through the same place at no
+    further charge.  You need not require recipients to copy the
+    Corresponding Source along with the object code.  If the place to
+    copy the object code is a network server, the Corresponding Source
+    may be on a different server (operated by you or a third party)
+    that supports equivalent copying facilities, provided you maintain
+    clear directions next to the object code saying where to find the
+    Corresponding Source.  Regardless of what server hosts the
+    Corresponding Source, you remain obligated to ensure that it is
+    available for as long as needed to satisfy these requirements.
+
+    e) Convey the object code using peer-to-peer transmission, provided
+    you inform other peers where the object code and Corresponding
+    Source of the work are being offered to the general public at no
+    charge under subsection 6d.
+
+  A separable portion of the object code, whose source code is excluded
+from the Corresponding Source as a System Library, need not be
+included in conveying the object code work.
+
+  A "User Product" is either (1) a "consumer product", which means any
+tangible personal property which is normally used for personal, family,
+or household purposes, or (2) anything designed or sold for incorporation
+into a dwelling.  In determining whether a product is a consumer product,
+doubtful cases shall be resolved in favor of coverage.  For a particular
+product received by a particular user, "normally used" refers to a
+typical or common use of that class of product, regardless of the status
+of the particular user or of the way in which the particular user
+actually uses, or expects or is expected to use, the product.  A product
+is a consumer product regardless of whether the product has substantial
+commercial, industrial or non-consumer uses, unless such uses represent
+the only significant mode of use of the product.
+
+  "Installation Information" for a User Product means any methods,
+procedures, authorization keys, or other information required to install
+and execute modified versions of a covered work in that User Product from
+a modified version of its Corresponding Source.  The information must
+suffice to ensure that the continued functioning of the modified object
+code is in no case prevented or interfered with solely because
+modification has been made.
+
+  If you convey an object code work under this section in, or with, or
+specifically for use in, a User Product, and the conveying occurs as
+part of a transaction in which the right of possession and use of the
+User Product is transferred to the recipient in perpetuity or for a
+fixed term (regardless of how the transaction is characterized), the
+Corresponding Source conveyed under this section must be accompanied
+by the Installation Information.  But this requirement does not apply
+if neither you nor any third party retains the ability to install
+modified object code on the User Product (for example, the work has
+been installed in ROM).
+
+  The requirement to provide Installation Information does not include a
+requirement to continue to provide support service, warranty, or updates
+for a work that has been modified or installed by the recipient, or for
+the User Product in which it has been modified or installed.  Access to a
+network may be denied when the modification itself materially and
+adversely affects the operation of the network or violates the rules and
+protocols for communication across the network.
+
+  Corresponding Source conveyed, and Installation Information provided,
+in accord with this section must be in a format that is publicly
+documented (and with an implementation available to the public in
+source code form), and must require no special password or key for
+unpacking, reading or copying.
+
+  7. Additional Terms.
+
+  "Additional permissions" are terms that supplement the terms of this
+License by making exceptions from one or more of its conditions.
+Additional permissions that are applicable to the entire Program shall
+be treated as though they were included in this License, to the extent
+that they are valid under applicable law.  If additional permissions
+apply only to part of the Program, that part may be used separately
+under those permissions, but the entire Program remains governed by
+this License without regard to the additional permissions.
+
+  When you convey a copy of a covered work, you may at your option
+remove any additional permissions from that copy, or from any part of
+it.  (Additional permissions may be written to require their own
+removal in certain cases when you modify the work.)  You may place
+additional permissions on material, added by you to a covered work,
+for which you have or can give appropriate copyright permission.
+
+  Notwithstanding any other provision of this License, for material you
+add to a covered work, you may (if authorized by the copyright holders of
+that material) supplement the terms of this License with terms:
+
+    a) Disclaiming warranty or limiting liability differently from the
+    terms of sections 15 and 16 of this License; or
+
+    b) Requiring preservation of specified reasonable legal notices or
+    author attributions in that material or in the Appropriate Legal
+    Notices displayed by works containing it; or
+
+    c) Prohibiting misrepresentation of the origin of that material, or
+    requiring that modified versions of such material be marked in
+    reasonable ways as different from the original version; or
+
+    d) Limiting the use for publicity purposes of names of licensors or
+    authors of the material; or
+
+    e) Declining to grant rights under trademark law for use of some
+    trade names, trademarks, or service marks; or
+
+    f) Requiring indemnification of licensors and authors of that
+    material by anyone who conveys the material (or modified versions of
+    it) with contractual assumptions of liability to the recipient, for
+    any liability that these contractual assumptions directly impose on
+    those licensors and authors.
+
+  All other non-permissive additional terms are considered "further
+restrictions" within the meaning of section 10.  If the Program as you
+received it, or any part of it, contains a notice stating that it is
+governed by this License along with a term that is a further
+restriction, you may remove that term.  If a license document contains
+a further restriction but permits relicensing or conveying under this
+License, you may add to a covered work material governed by the terms
+of that license document, provided that the further restriction does
+not survive such relicensing or conveying.
+
+  If you add terms to a covered work in accord with this section, you
+must place, in the relevant source files, a statement of the
+additional terms that apply to those files, or a notice indicating
+where to find the applicable terms.
+
+  Additional terms, permissive or non-permissive, may be stated in the
+form of a separately written license, or stated as exceptions;
+the above requirements apply either way.
+
+  8. Termination.
+
+  You may not propagate or modify a covered work except as expressly
+provided under this License.  Any attempt otherwise to propagate or
+modify it is void, and will automatically terminate your rights under
+this License (including any patent licenses granted under the third
+paragraph of section 11).
+
+  However, if you cease all violation of this License, then your
+license from a particular copyright holder is reinstated (a)
+provisionally, unless and until the copyright holder explicitly and
+finally terminates your license, and (b) permanently, if the copyright
+holder fails to notify you of the violation by some reasonable means
+prior to 60 days after the cessation.
+
+  Moreover, your license from a particular copyright holder is
+reinstated permanently if the copyright holder notifies you of the
+violation by some reasonable means, this is the first time you have
+received notice of violation of this License (for any work) from that
+copyright holder, and you cure the violation prior to 30 days after
+your receipt of the notice.
+
+  Termination of your rights under this section does not terminate the
+licenses of parties who have received copies or rights from you under
+this License.  If your rights have been terminated and not permanently
+reinstated, you do not qualify to receive new licenses for the same
+material under section 10.
+
+  9. Acceptance Not Required for Having Copies.
+
+  You are not required to accept this License in order to receive or
+run a copy of the Program.  Ancillary propagation of a covered work
+occurring solely as a consequence of using peer-to-peer transmission
+to receive a copy likewise does not require acceptance.  However,
+nothing other than this License grants you permission to propagate or
+modify any covered work.  These actions infringe copyright if you do
+not accept this License.  Therefore, by modifying or propagating a
+covered work, you indicate your acceptance of this License to do so.
+
+  10. Automatic Licensing of Downstream Recipients.
+
+  Each time you convey a covered work, the recipient automatically
+receives a license from the original licensors, to run, modify and
+propagate that work, subject to this License.  You are not responsible
+for enforcing compliance by third parties with this License.
+
+  An "entity transaction" is a transaction transferring control of an
+organization, or substantially all assets of one, or subdividing an
+organization, or merging organizations.  If propagation of a covered
+work results from an entity transaction, each party to that
+transaction who receives a copy of the work also receives whatever
+licenses to the work the party's predecessor in interest had or could
+give under the previous paragraph, plus a right to possession of the
+Corresponding Source of the work from the predecessor in interest, if
+the predecessor has it or can get it with reasonable efforts.
+
+  You may not impose any further restrictions on the exercise of the
+rights granted or affirmed under this License.  For example, you may
+not impose a license fee, royalty, or other charge for exercise of
+rights granted under this License, and you may not initiate litigation
+(including a cross-claim or counterclaim in a lawsuit) alleging that
+any patent claim is infringed by making, using, selling, offering for
+sale, or importing the Program or any portion of it.
+
+  11. Patents.
+
+  A "contributor" is a copyright holder who authorizes use under this
+License of the Program or a work on which the Program is based.  The
+work thus licensed is called the contributor's "contributor version".
+
+  A contributor's "essential patent claims" are all patent claims
+owned or controlled by the contributor, whether already acquired or
+hereafter acquired, that would be infringed by some manner, permitted
+by this License, of making, using, or selling its contributor version,
+but do not include claims that would be infringed only as a
+consequence of further modification of the contributor version.  For
+purposes of this definition, "control" includes the right to grant
+patent sublicenses in a manner consistent with the requirements of
+this License.
+
+  Each contributor grants you a non-exclusive, worldwide, royalty-free
+patent license under the contributor's essential patent claims, to
+make, use, sell, offer for sale, import and otherwise run, modify and
+propagate the contents of its contributor version.
+
+  In the following three paragraphs, a "patent license" is any express
+agreement or commitment, however denominated, not to enforce a patent
+(such as an express permission to practice a patent or covenant not to
+sue for patent infringement).  To "grant" such a patent license to a
+party means to make such an agreement or commitment not to enforce a
+patent against the party.
+
+  If you convey a covered work, knowingly relying on a patent license,
+and the Corresponding Source of the work is not available for anyone
+to copy, free of charge and under the terms of this License, through a
+publicly available network server or other readily accessible means,
+then you must either (1) cause the Corresponding Source to be so
+available, or (2) arrange to deprive yourself of the benefit of the
+patent license for this particular work, or (3) arrange, in a manner
+consistent with the requirements of this License, to extend the patent
+license to downstream recipients.  "Knowingly relying" means you have
+actual knowledge that, but for the patent license, your conveying the
+covered work in a country, or your recipient's use of the covered work
+in a country, would infringe one or more identifiable patents in that
+country that you have reason to believe are valid.
+
+  If, pursuant to or in connection with a single transaction or
+arrangement, you convey, or propagate by procuring conveyance of, a
+covered work, and grant a patent license to some of the parties
+receiving the covered work authorizing them to use, propagate, modify
+or convey a specific copy of the covered work, then the patent license
+you grant is automatically extended to all recipients of the covered
+work and works based on it.
+
+  A patent license is "discriminatory" if it does not include within
+the scope of its coverage, prohibits the exercise of, or is
+conditioned on the non-exercise of one or more of the rights that are
+specifically granted under this License.  You may not convey a covered
+work if you are a party to an arrangement with a third party that is
+in the business of distributing software, under which you make payment
+to the third party based on the extent of your activity of conveying
+the work, and under which the third party grants, to any of the
+parties who would receive the covered work from you, a discriminatory
+patent license (a) in connection with copies of the covered work
+conveyed by you (or copies made from those copies), or (b) primarily
+for and in connection with specific products or compilations that
+contain the covered work, unless you entered into that arrangement,
+or that patent license was granted, prior to 28 March 2007.
+
+  Nothing in this License shall be construed as excluding or limiting
+any implied license or other defenses to infringement that may
+otherwise be available to you under applicable patent law.
+
+  12. No Surrender of Others' Freedom.
+
+  If conditions are imposed on you (whether by court order, agreement or
+otherwise) that contradict the conditions of this License, they do not
+excuse you from the conditions of this License.  If you cannot convey a
+covered work so as to satisfy simultaneously your obligations under this
+License and any other pertinent obligations, then as a consequence you may
+not convey it at all.  For example, if you agree to terms that obligate you
+to collect a royalty for further conveying from those to whom you convey
+the Program, the only way you could satisfy both those terms and this
+License would be to refrain entirely from conveying the Program.
+
+  13. Remote Network Interaction; Use with the GNU General Public License.
+
+  Notwithstanding any other provision of this License, if you modify the
+Program, your modified version must prominently offer all users
+interacting with it remotely through a computer network (if your version
+supports such interaction) an opportunity to receive the Corresponding
+Source of your version by providing access to the Corresponding Source
+from a network server at no charge, through some standard or customary
+means of facilitating copying of software.  This Corresponding Source
+shall include the Corresponding Source for any work covered by version 3
+of the GNU General Public License that is incorporated pursuant to the
+following paragraph.
+
+  Notwithstanding any other provision of this License, you have
+permission to link or combine any covered work with a work licensed
+under version 3 of the GNU General Public License into a single
+combined work, and to convey the resulting work.  The terms of this
+License will continue to apply to the part which is the covered work,
+but the work with which it is combined will remain governed by version
+3 of the GNU General Public License.
+
+  14. Revised Versions of this License.
+
+  The Free Software Foundation may publish revised and/or new versions of
+the GNU Affero General Public License from time to time.  Such new versions
+will be similar in spirit to the present version, but may differ in detail to
+address new problems or concerns.
+
+  Each version is given a distinguishing version number.  If the
+Program specifies that a certain numbered version of the GNU Affero General
+Public License "or any later version" applies to it, you have the
+option of following the terms and conditions either of that numbered
+version or of any later version published by the Free Software
+Foundation.  If the Program does not specify a version number of the
+GNU Affero General Public License, you may choose any version ever published
+by the Free Software Foundation.
+
+  If the Program specifies that a proxy can decide which future
+versions of the GNU Affero General Public License can be used, that proxy's
+public statement of acceptance of a version permanently authorizes you
+to choose that version for the Program.
+
+  Later license versions may give you additional or different
+permissions.  However, no additional obligations are imposed on any
+author or copyright holder as a result of your choosing to follow a
+later version.
+
+  15. Disclaimer of Warranty.
+
+  THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY
+APPLICABLE LAW.  EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT
+HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY
+OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO,
+THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+PURPOSE.  THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM
+IS WITH YOU.  SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF
+ALL NECESSARY SERVICING, REPAIR OR CORRECTION.
+
+  16. Limitation of Liability.
+
+  IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
+WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS
+THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
+GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE
+USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF
+DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD
+PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS),
+EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF
+SUCH DAMAGES.
+
+  17. Interpretation of Sections 15 and 16.
+
+  If the disclaimer of warranty and limitation of liability provided
+above cannot be given local legal effect according to their terms,
+reviewing courts shall apply local law that most closely approximates
+an absolute waiver of all civil liability in connection with the
+Program, unless a warranty or assumption of liability accompanies a
+copy of the Program in return for a fee.
+
+                     END OF TERMS AND CONDITIONS
+
+            How to Apply These Terms to Your New Programs
+
+  If you develop a new program, and you want it to be of the greatest
+possible use to the public, the best way to achieve this is to make it
+free software which everyone can redistribute and change under these terms.
+
+  To do so, attach the following notices to the program.  It is safest
+to attach them to the start of each source file to most effectively
+state the exclusion of warranty; and each file should have at least
+the "copyright" line and a pointer to where the full notice is found.
+
+    <one line to give the program's name and a brief idea of what it does.>
+    Copyright (C) <year>  <name of author>
+
+    This program is free software: you can redistribute it and/or modify
+    it under the terms of the GNU Affero General Public License as published
+    by the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU Affero General Public License for more details.
+
+    You should have received a copy of the GNU Affero General Public License
+    along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+Also add information on how to contact you by electronic and paper mail.
+
+  If your software can interact with users remotely through a computer
+network, you should also make sure that it provides a way for users to
+get its source.  For example, if your program is a web application, its
+interface could display a "Source" link that leads users to an archive
+of the code.  There are many ways you could offer source, and different
+solutions will be better for different programs; see section 13 for the
+specific requirements.
+
+  You should also get your employer (if you work as a programmer) or school,
+if any, to sign a "copyright disclaimer" for the program, if necessary.
+For more information on this, and how to apply and follow the GNU AGPL, see
+<https://www.gnu.org/licenses/>.

build/buildProjects.bat

@@ -0,0 +1,3 @@
+dotnet build ../src/Connected.ServiceModel.Client/Connected.ServiceModel.Client.csproj
+dotnet build ../src/Connected.ServiceModel.Client.Storage/Connected.ServiceModel.Client.Storage.csproj
+dotnet build ../src/Connected.ServiceModel.Client.Data/Connected.ServiceModel.Client.Data.csproj

nuget.config

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="utf-8"?>
+<configuration>
+    <config>
+        <add key="repositoryPath" value="%PACKAGEHOME%/External" />
+    </config>
+
+    <packageRestore>
+        <add key="enabled" value="True" />
+        <add key="automatic" value="True" />
+    </packageRestore>
+    <packageSources>
+        <add key="NuGet official package source" value="https://api.nuget.org/v3/index.json" />
+		<add key="Local repository" value="%LOCAL_NUGET%" />
+    </packageSources>
+
+    <disabledPackageSources />
+</configuration>

src/Connected.ServiceModel.Client.Data/AggregatedCommandBuilder.cs

@@ -0,0 +1,50 @@
+using System.Collections.Immutable;
+using Connected.Entities;
+using Connected.Entities.Storage;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class AggregatedCommandBuilder<TEntity>
+{
+	public StorageOperation? Build(TEntity entity)
+	{
+		if (entity is not IEntity ie)
+			throw new ArgumentException(nameof(entity));
+
+		switch (ie.State)
+		{
+			case State.New:
+				return BuildInsert(ie);
+			case State.Default:
+				return BuildUpdate(ie);
+			case State.Deleted:
+				return BuildDelete(ie);
+			default:
+				throw new NotSupportedException();
+		}
+	}
+
+	public List<StorageOperation> Build(ImmutableArray<TEntity> entities)
+	{
+		var result = new List<StorageOperation>();
+
+		foreach (var entity in entities)
+			result.Add(Build(entity));
+
+		return result;
+	}
+
+	private StorageOperation? BuildInsert(IEntity entity)
+	{
+		return new InsertCommandBuilder().Build(entity);
+	}
+
+	private StorageOperation? BuildUpdate(IEntity entity)
+	{
+		return new UpdateCommandBuilder().Build(entity);
+	}
+
+	private StorageOperation? BuildDelete(IEntity entity)
+	{
+		return new DeleteCommandBuilder().Build(entity);
+	}
+}

src/Connected.ServiceModel.Client.Data/Boot.cs

@@ -0,0 +1,15 @@
+using Connected.Annotations;
+using Connected.ServiceModel.Client.Data.Remote;
+using Microsoft.Extensions.DependencyInjection;
+
+[assembly: MicroService(MicroServiceType.Provider)]
+
+namespace Connected.ServiceModel.Client.Data;
+
+internal sealed class Boot : Startup
+{
+	protected override void OnConfigureServices(IServiceCollection services)
+	{
+		services.AddScoped<RemoteTableService>();
+	}
+}

src/Connected.ServiceModel.Client.Data/CommandBuilder.cs

@@ -0,0 +1,206 @@
+using System.Data;
+using System.Reflection;
+using System.Text;
+using Connected.Entities;
+using Connected.Entities.Annotations;
+using Connected.Entities.Storage;
+using Connected.Interop;
+
+namespace Connected.ServiceModel.Client.Data;
+
+internal abstract class CommandBuilder
+{
+	private readonly List<IStorageParameter> _parameters;
+	private readonly List<PropertyInfo> _whereProperties;
+	private List<PropertyInfo> _properties;
+
+	protected CommandBuilder()
+	{
+		_parameters = new List<IStorageParameter>();
+		_whereProperties = new List<PropertyInfo>();
+
+		Text = new StringBuilder();
+	}
+
+	public StorageOperation? Build(IEntity entity)
+	{
+		Entity = entity;
+
+		if (TryGetExisting(out StorageOperation? existing))
+		{
+			/*
+			 * We need to rebuild an instance since StorageOperation
+			 * is immutable
+			 */
+			var result = new StorageOperation
+			{
+				CommandText = existing.CommandText,
+				CommandTimeout = existing.CommandTimeout,
+				CommandType = existing.CommandType,
+				Concurrency = existing.Concurrency
+			};
+
+			if (result.Parameters is null)
+				return result;
+
+			foreach (var parameter in result.Parameters)
+			{
+				if (parameter.Direction == ParameterDirection.Input)
+				{
+					if (ResolveProperty(parameter.Name) is PropertyInfo property)
+					{
+						result.AddParameter(new StorageParameter
+						{
+							Value = GetValue(property),
+							Name = parameter.Name,
+							Type = parameter.Type,
+							Direction = parameter.Direction
+						});
+					}
+				}
+			}
+
+			return result;
+		}
+
+		Schema = Entity.GetSchemaAttribute();
+
+		return OnBuild();
+	}
+
+	protected List<PropertyInfo> Properties => _properties ??= GetProperties();
+
+	protected List<PropertyInfo> WhereProperties => _whereProperties;
+
+	protected string CommandText => Text.ToString();
+
+	protected IEntity Entity { get; private set; }
+
+	protected SchemaAttribute Schema { get; private set; }
+
+	private StringBuilder Text { get; set; }
+
+	protected abstract StorageOperation OnBuild();
+
+	protected abstract bool TryGetExisting(out StorageOperation? result);
+
+	protected List<IStorageParameter> Parameters => _parameters;
+
+	protected void Write(string text)
+	{
+		Text.Append(text);
+	}
+
+	protected void Write(char text)
+	{
+		Text.Append(text);
+	}
+
+	protected void WriteLine(string text)
+	{
+		Text.AppendLine(text);
+	}
+
+	protected void Trim()
+	{
+		for (var i = Text.Length - 1; i >= 0; i--)
+		{
+			if (!Text[i].Equals(',') && !Text[i].Equals('\n') && !Text[i].Equals('\r') && !Text[i].Equals(' '))
+				break;
+
+			if (i < Text.Length)
+				Text.Length = i;
+		}
+	}
+
+	protected virtual List<PropertyInfo> GetProperties()
+	{
+		return Interop.Properties.GetImplementedProperties(Entity);
+	}
+
+	protected static string ColumnName(PropertyInfo property)
+	{
+		var dataMember = property.FindAttribute<MemberAttribute>();
+
+		return dataMember is null || string.IsNullOrEmpty(dataMember.Member) ? property.Name.ToCamelCase() : dataMember.Member;
+	}
+
+	protected static DbType ResolveDbType(PropertyInfo property)
+	{
+		return property.PropertyType.ToDbType();
+	}
+
+	protected object? GetValue(PropertyInfo property)
+	{
+		if (IsNull(property))
+			return "NULL";
+
+		return GetValue(property.GetValue(Entity), property.PropertyType.ToDbType());
+	}
+
+	private static object? GetValue(object value, DbType dbType)
+	{
+		switch (dbType)
+		{
+			case DbType.Binary:
+				if (value is byte[] bytes)
+					return Convert.ToBase64String(bytes);
+				else
+					return Convert.ToBase64String(Encoding.UTF8.GetBytes(value.ToString()));
+			default:
+				return value;
+		}
+	}
+
+	private bool IsNull(PropertyInfo property)
+	{
+		var result = property.GetValue(Entity);
+
+		if (result is null)
+			return true;
+
+		if (property.GetCustomAttribute<NullableAttribute>() is null)
+			return false;
+
+		var def = Types.GetDefault(property.PropertyType);
+
+		return TypeComparer.Compare(result, def);
+	}
+
+	protected StorageParameter CreateParameter(PropertyInfo property)
+	{
+		return CreateParameter(property, ParameterDirection.Input);
+	}
+
+	protected StorageParameter CreateParameter(PropertyInfo property, ParameterDirection direction)
+	{
+		var columnName = ColumnName(property);
+		var parameterName = $"@{columnName}";
+
+		var parameter = new StorageParameter
+		{
+			Direction = direction,
+			Name = parameterName,
+			Type = ResolveDbType(property),
+			Value = GetValue(property)
+		};
+
+		Parameters.Add(parameter);
+
+		return parameter;
+	}
+
+	private PropertyInfo ResolveProperty(string parameterName)
+	{
+		var propertyName = parameterName[1..];
+		var flags = BindingFlags.Public | BindingFlags.Instance | BindingFlags.NonPublic;
+
+		if (Entity.GetType().GetProperty(propertyName.ToPascalCase(), flags) is PropertyInfo property)
+			return property;
+
+		if (Entity.GetType().GetProperty(propertyName, flags) is PropertyInfo raw)
+			return raw;
+
+		return null;
+	}
+}

src/Connected.ServiceModel.Client.Data/Connected.ServiceModel.Client.Data.csproj

@@ -0,0 +1,47 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+	<PropertyGroup>
+		<TargetFramework>net7.0</TargetFramework>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Nullable>enable</Nullable>
+		<GeneratePackageOnBuild>True</GeneratePackageOnBuild>
+		<Title>$(AssemblyName)</Title>
+		<Authors>Tom PIT ltd</Authors>
+		<Copyright>2022 Tom PIT ltd</Copyright>
+		<PackageProjectUrl>https://git.tompit.com/Connected/Info</PackageProjectUrl>
+		<PackageReadmeFile>README.md</PackageReadmeFile>
+		<PackageTags>connected;platform;</PackageTags>
+		<IncludeSymbols>True</IncludeSymbols>
+		<SymbolPackageFormat>snupkg</SymbolPackageFormat>
+		<PackageLicenseFile>LICENSE</PackageLicenseFile>
+		<PackageOutputPath>$(OutputPath)</PackageOutputPath>
+	</PropertyGroup>
+
+	<ItemGroup>
+		<PackageReference Include="Connected.ServiceModel" Version="1.0.*-*" />
+		<PackageReference Include="Connected.Data" Version="1.0.*-*" />
+		<PackageReference Include="Connected.Entities" Version="1.0.*-*" />
+		<PackageReference Include="Connected.Services" Version="1.0.*-*" />
+		<PackageReference Include="Connected.ServiceModel.Client" Version="1.0.*-*" />
+		<PackageReference Include="Nerdbank.GitVersioning"
+									Version="3.5.119"
+									PrivateAssets="all"
+									Condition="!Exists('packages.config')" />
+	</ItemGroup>
+
+	<ItemGroup>
+		<None Include="..\..\LICENSE">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+		<None Include="..\..\README.md">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+	</ItemGroup>
+
+	<Target Name="CopyPackages" AfterTargets="Pack">
+		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
+		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
+	</Target>
+</Project>

src/Connected.ServiceModel.Client.Data/CqlDataType.cs

@@ -0,0 +1,17 @@
+using Connected.Expressions.Languages;
+using System.Data;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class CqlDataType : DataType
+{
+	public CqlDataType(SqlDbType dbType, bool notNull, int length, short precision, short scale)
+	{
+		DbType = dbType;
+		NotNull = notNull;
+		Length = length;
+		Precision = precision;
+		Scale = scale;
+	}
+
+	public SqlDbType DbType { get; }
+}

src/Connected.ServiceModel.Client.Data/CqlFormatter.cs

@@ -0,0 +1,781 @@
+using System.Linq.Expressions;
+using Connected.Expressions;
+using Connected.Expressions.Formatters;
+using Connected.Expressions.Languages;
+using Connected.Interop;
+
+namespace Connected.ServiceModel.Client.Data;
+/// <summary>
+/// This is currently the same implementation as the default (TSql) formatter.
+/// </summary>
+internal sealed class CqlFormatter : SqlFormatter
+{
+	public CqlFormatter(ExpressionCompilationContext context, QueryLanguage? language)
+		  : base(language)
+	{
+		Context = context;
+
+		HideColumnAliases = true;
+		HideTableAliases = true;
+		UseBracketsInWhere = false;
+	}
+
+	public ExpressionCompilationContext Context { get; }
+
+	public static new string Format(ExpressionCompilationContext context, Expression expression)
+	{
+		return Format(context, expression, new CqlLanguage());
+	}
+	public static string Format(ExpressionCompilationContext context, Expression expression, QueryLanguage language)
+	{
+		var formatter = new CqlFormatter(context, language);
+
+		formatter.Visit(expression);
+
+		return formatter.ToString();
+	}
+	protected override void WriteAggregateName(string aggregateName)
+	{
+		if (string.Equals(aggregateName, "LongCount", StringComparison.Ordinal))
+			Write("COUNT_BIG");
+		else
+			base.WriteAggregateName(aggregateName);
+	}
+
+	protected override void WriteTableName(string tableSchema, string tableName)
+	{
+		Write(tableName);
+	}
+	protected override Expression VisitMemberAccess(MemberExpression m)
+	{
+		if (m.Member.DeclaringType == typeof(string))
+		{
+			switch (m.Member.Name)
+			{
+				case "Length":
+					Write("LEN(");
+					Visit(m.Expression);
+					Write(")");
+					return m;
+			}
+		}
+		else if (m.Member.DeclaringType == typeof(DateTime) || m.Member.DeclaringType == typeof(DateTimeOffset))
+		{
+			switch (m.Member.Name)
+			{
+				case "Day":
+					Write("DAY(");
+					Visit(m.Expression);
+					Write(")");
+					return m;
+				case "Month":
+					Write("MONTH(");
+					Visit(m.Expression);
+					Write(")");
+					return m;
+				case "Year":
+					Write("YEAR(");
+					Visit(m.Expression);
+					Write(")");
+					return m;
+				case "Hour":
+					Write("DATEPART(hour, ");
+					Visit(m.Expression);
+					Write(")");
+					return m;
+				case "Minute":
+					Write("DATEPART(minute, ");
+					Visit(m.Expression);
+					Write(")");
+					return m;
+				case "Second":
+					Write("DATEPART(second, ");
+					Visit(m.Expression);
+					Write(")");
+					return m;
+				case "Millisecond":
+					Write("DATEPART(millisecond, ");
+					Visit(m.Expression);
+					Write(")");
+					return m;
+				case "DayOfWeek":
+					Write("(DATEPART(weekday, ");
+					Visit(m.Expression);
+					Write(") - 1)");
+					return m;
+				case "DayOfYear":
+					Write("(DATEPART(dayofyear, ");
+					Visit(m.Expression);
+					Write(") - 1)");
+					return m;
+			}
+		}
+
+		return base.VisitMemberAccess(m);
+	}
+
+	protected override Expression VisitMethodCall(MethodCallExpression m)
+	{
+		if (m.Method.DeclaringType == typeof(string))
+		{
+			switch (m.Method.Name)
+			{
+				case "StartsWith":
+					Write("(");
+					Visit(m.Object);
+					Write(" LIKE ");
+					Visit(m.Arguments[0]);
+					Write(" + '%')");
+					return m;
+				case "EndsWith":
+					Write("(");
+					Visit(m.Object);
+					Write(" LIKE '%' + ");
+					Visit(m.Arguments[0]);
+					Write(")");
+					return m;
+				case "Contains":
+					Write("(");
+					Visit(m.Object);
+					Write(" LIKE '%' + ");
+					Visit(m.Arguments[0]);
+					Write(" + '%')");
+					return m;
+				case "Concat":
+					var args = m.Arguments;
+
+					if (args.Count == 1 && args[0].NodeType == ExpressionType.NewArrayInit)
+						args = ((NewArrayExpression)args[0]).Expressions;
+					for (var i = 0; i < args.Count; i++)
+					{
+						if (i > 0)
+							Write(" + ");
+
+						Visit(args[i]);
+					}
+					return m;
+				case "IsNullOrEmpty":
+					Write("(");
+					Visit(m.Arguments[0]);
+					Write(" IS NULL OR ");
+					Visit(m.Arguments[0]);
+					Write(" = '')");
+					return m;
+				case "ToUpper":
+					Write("UPPER(");
+					Visit(m.Object);
+					Write(")");
+					return m;
+				case "ToLower":
+					Write("LOWER(");
+					Visit(m.Object);
+					Write(")");
+					return m;
+				case "Replace":
+					Write("REPLACE(");
+					Visit(m.Object);
+					Write(", ");
+					Visit(m.Arguments[0]);
+					Write(", ");
+					Visit(m.Arguments[1]);
+					Write(")");
+					return m;
+				case "Substring":
+					Write("SUBSTRING(");
+					Visit(m.Object);
+					Write(", ");
+					Visit(m.Arguments[0]);
+					Write(" + 1, ");
+
+					if (m.Arguments.Count == 2)
+						Visit(m.Arguments[1]);
+					else
+						Write("8000");
+
+					Write(")");
+					return m;
+				case "Remove":
+					Write("STUFF(");
+					Visit(m.Object);
+					Write(", ");
+					Visit(m.Arguments[0]);
+					Write(" + 1, ");
+
+					if (m.Arguments.Count == 2)
+						Visit(m.Arguments[1]);
+					else
+						Write("8000");
+
+					Write(", '')");
+					return m;
+				case "IndexOf":
+					Write("(CHARINDEX(");
+					Visit(m.Arguments[0]);
+					Write(", ");
+					Visit(m.Object);
+
+					if (m.Arguments.Count == 2 && m.Arguments[1].Type == typeof(int))
+					{
+						Write(", ");
+						Visit(m.Arguments[1]);
+						Write(" + 1");
+					}
+
+					Write(") - 1)");
+					return m;
+				case "Trim":
+					Write("RTRIM(LTRIM(");
+					Visit(m.Object);
+					Write("))");
+					return m;
+			}
+		}
+		else if (m.Method.DeclaringType == typeof(DateTime))
+		{
+			switch (m.Method.Name)
+			{
+				case "op_Subtract":
+					if (m.Arguments[1].Type == typeof(DateTime))
+					{
+						Write("DATEDIFF(");
+						Visit(m.Arguments[0]);
+						Write(", ");
+						Visit(m.Arguments[1]);
+						Write(")");
+						return m;
+					}
+					break;
+				case "AddYears":
+					Write("DATEADD(YYYY,");
+					Visit(m.Arguments[0]);
+					Write(",");
+					Visit(m.Object);
+					Write(")");
+					return m;
+				case "AddMonths":
+					Write("DATEADD(MM,");
+					Visit(m.Arguments[0]);
+					Write(",");
+					Visit(m.Object);
+					Write(")");
+					return m;
+				case "AddDays":
+					Write("DATEADD(DAY,");
+					Visit(m.Arguments[0]);
+					Write(",");
+					Visit(m.Object);
+					Write(")");
+					return m;
+				case "AddHours":
+					Write("DATEADD(HH,");
+					Visit(m.Arguments[0]);
+					Write(",");
+					Visit(m.Object);
+					Write(")");
+					return m;
+				case "AddMinutes":
+					Write("DATEADD(MI,");
+					Visit(m.Arguments[0]);
+					Write(",");
+					Visit(m.Object);
+					Write(")");
+					return m;
+				case "AddSeconds":
+					Write("DATEADD(SS,");
+					Visit(m.Arguments[0]);
+					Write(",");
+					Visit(m.Object);
+					Write(")");
+					return m;
+				case "AddMilliseconds":
+					Write("DATEADD(MS,");
+					Visit(m.Arguments[0]);
+					Write(",");
+					Visit(m.Object);
+					Write(")");
+					return m;
+			}
+		}
+		else if (m.Method.DeclaringType == typeof(Decimal))
+		{
+			switch (m.Method.Name)
+			{
+				case "Add":
+				case "Subtract":
+				case "Multiply":
+				case "Divide":
+				case "Remainder":
+					Write("(");
+					VisitValue(m.Arguments[0]);
+					Write(" ");
+					Write(GetOperator(m.Method.Name));
+					Write(" ");
+					VisitValue(m.Arguments[1]);
+					Write(")");
+					return m;
+				case "Negate":
+					Write("-");
+					Visit(m.Arguments[0]);
+					Write("");
+					return m;
+				case "Ceiling":
+				case "Floor":
+					Write(m.Method.Name.ToUpper());
+					Write("(");
+					Visit(m.Arguments[0]);
+					Write(")");
+					return m;
+				case "Round":
+					if (m.Arguments.Count == 1)
+					{
+						Write("ROUND(");
+						Visit(m.Arguments[0]);
+						Write(", 0)");
+						return m;
+					}
+					else if (m.Arguments.Count == 2 && m.Arguments[1].Type == typeof(int))
+					{
+						Write("ROUND(");
+						Visit(m.Arguments[0]);
+						Write(", ");
+						Visit(m.Arguments[1]);
+						Write(")");
+						return m;
+					}
+					break;
+				case "Truncate":
+					Write("ROUND(");
+					Visit(m.Arguments[0]);
+					Write(", 0, 1)");
+					return m;
+			}
+		}
+		else if (m.Method.DeclaringType == typeof(Math))
+		{
+			switch (m.Method.Name)
+			{
+				case "Abs":
+				case "Acos":
+				case "Asin":
+				case "Atan":
+				case "Cos":
+				case "Exp":
+				case "Log10":
+				case "Sin":
+				case "Tan":
+				case "Sqrt":
+				case "Sign":
+				case "Ceiling":
+				case "Floor":
+					Write(m.Method.Name.ToUpper());
+					Write("(");
+					Visit(m.Arguments[0]);
+					Write(")");
+					return m;
+				case "Atan2":
+					Write("ATN2(");
+					Visit(m.Arguments[0]);
+					Write(", ");
+					Visit(m.Arguments[1]);
+					Write(")");
+					return m;
+				case "Log":
+					if (m.Arguments.Count == 1)
+						goto case "Log10";
+
+					break;
+				case "Pow":
+					Write("POWER(");
+					Visit(m.Arguments[0]);
+					Write(", ");
+					Visit(m.Arguments[1]);
+					Write(")");
+					return m;
+				case "Round":
+					if (m.Arguments.Count == 1)
+					{
+						Write("ROUND(");
+						Visit(m.Arguments[0]);
+						Write(", 0)");
+						return m;
+					}
+					else if (m.Arguments.Count == 2 && m.Arguments[1].Type == typeof(int))
+					{
+						Write("ROUND(");
+						Visit(m.Arguments[0]);
+						Write(", ");
+						Visit(m.Arguments[1]);
+						Write(")");
+						return m;
+					}
+					break;
+				case "Truncate":
+					Write("ROUND(");
+					Visit(m.Arguments[0]);
+					Write(", 0, 1)");
+					return m;
+			}
+		}
+		if (m.Method.Name == "ToString")
+		{
+			if (m.Object.Type != typeof(string))
+			{
+				Write("CONVERT(NVARCHAR, ");
+				Visit(m.Object);
+				Write(")");
+			}
+			else
+				Visit(m.Object);
+
+			return m;
+		}
+		else if (!m.Method.IsStatic && string.Equals(m.Method.Name, "CompareTo", StringComparison.Ordinal) && m.Method.ReturnType == typeof(int) && m.Arguments.Count == 1)
+		{
+			Write("(CASE WHEN ");
+			Visit(m.Object);
+			Write(" = ");
+			Visit(m.Arguments[0]);
+			Write(" THEN 0 WHEN ");
+			Visit(m.Object);
+			Write(" < ");
+			Visit(m.Arguments[0]);
+			Write(" THEN -1 ELSE 1 END)");
+			return m;
+		}
+		else if (m.Method.IsStatic && string.Equals(m.Method.Name, "Compare", StringComparison.Ordinal) && m.Method.ReturnType == typeof(int) && m.Arguments.Count == 2)
+		{
+			Write("(CASE WHEN ");
+			Visit(m.Arguments[0]);
+			Write(" = ");
+			Visit(m.Arguments[1]);
+			Write(" THEN 0 WHEN ");
+			Visit(m.Arguments[0]);
+			Write(" < ");
+			Visit(m.Arguments[1]);
+			Write(" THEN -1 ELSE 1 END)");
+			return m;
+		}
+		else if (m.Method.DeclaringType == typeof(TypeComparer) && m.Method.IsStatic && string.Equals(m.Method.Name, nameof(TypeComparer.Compare), StringComparison.Ordinal) && m.Method.ReturnType == typeof(bool) && m.Arguments.Count == 2)
+		{
+			Visit(m.Arguments[0]);
+			Write(" = ");
+			Visit(m.Arguments[1]);
+			return m;
+		}
+		return base.VisitMethodCall(m);
+	}
+
+	protected override NewExpression VisitNew(NewExpression nex)
+	{
+		if (nex.Constructor.DeclaringType == typeof(DateTime))
+		{
+			if (nex.Arguments.Count == 3)
+			{
+				Write("Convert(DateTime, ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[0]);
+				Write(") + '/' + ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[1]);
+				Write(") + '/' + ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[2]);
+				Write("))");
+				return nex;
+			}
+			else if (nex.Arguments.Count == 6)
+			{
+				Write("Convert(DateTime, ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[0]);
+				Write(") + '/' + ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[1]);
+				Write(") + '/' + ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[2]);
+				Write(") + ' ' + ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[3]);
+				Write(") + ':' + ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[4]);
+				Write(") + ':' + ");
+				Write("Convert(nvarchar, ");
+				Visit(nex.Arguments[5]);
+				Write("))");
+				return nex;
+			}
+		}
+
+		return base.VisitNew(nex);
+	}
+
+	protected override Expression VisitBinary(BinaryExpression b)
+	{
+		if (b.NodeType == ExpressionType.Power)
+		{
+			Write("POWER(");
+			VisitValue(b.Left);
+			Write(", ");
+			VisitValue(b.Right);
+			Write(")");
+			return b;
+		}
+		else if (b.NodeType == ExpressionType.Coalesce)
+		{
+			Write("COALESCE(");
+			VisitValue(b.Left);
+			Write(", ");
+
+			var right = b.Right;
+
+			while (right.NodeType == ExpressionType.Coalesce)
+			{
+				var rb = (BinaryExpression)right;
+
+				VisitValue(rb.Left);
+				Write(", ");
+
+				right = rb.Right;
+			}
+
+			VisitValue(right);
+			Write(")");
+
+			return b;
+		}
+		else if (b.NodeType == ExpressionType.LeftShift)
+		{
+			Write("(");
+			VisitValue(b.Left);
+			Write(" * POWER(2, ");
+			VisitValue(b.Right);
+			Write("))");
+			return b;
+		}
+		else if (b.NodeType == ExpressionType.RightShift)
+		{
+			Write("(");
+			VisitValue(b.Left);
+			Write(" / POWER(2, ");
+			VisitValue(b.Right);
+			Write("))");
+			return b;
+		}
+
+		return base.VisitBinary(b);
+	}
+
+	protected override Expression VisitConstant(ConstantExpression c)
+	{
+		var parameter = Context.Parameters.FirstOrDefault(f => f.Value == c);
+
+		if (parameter.Value is not null)
+		{
+			Write($"@{parameter.Key}");
+
+			return c;
+		}
+
+		return base.VisitConstant(c);
+	}
+
+	protected override Expression VisitValue(Expression expr)
+	{
+		if (IsPredicate(expr))
+		{
+			Write("CASE WHEN (");
+			Visit(expr);
+			Write(") THEN 1 ELSE 0 END");
+
+			return expr;
+		}
+
+		return base.VisitValue(expr);
+	}
+
+	protected override Expression VisitConditional(ConditionalExpression c)
+	{
+		if (IsPredicate(c.Test))
+		{
+			Write("(CASE WHEN ");
+			VisitPredicate(c.Test);
+			Write(" THEN ");
+			VisitValue(c.IfTrue);
+
+			var ifFalse = c.IfFalse;
+
+			while (ifFalse is not null && ifFalse.NodeType == ExpressionType.Conditional)
+			{
+				var fc = (ConditionalExpression)ifFalse;
+
+				Write(" WHEN ");
+				VisitPredicate(fc.Test);
+				Write(" THEN ");
+				VisitValue(fc.IfTrue);
+
+				ifFalse = fc.IfFalse;
+			}
+			if (ifFalse is not null)
+			{
+				Write(" ELSE ");
+				VisitValue(ifFalse);
+			}
+
+			Write(" END)");
+		}
+		else
+		{
+			Write("(CASE ");
+			VisitValue(c.Test);
+			Write(" WHEN 0 THEN ");
+			VisitValue(c.IfFalse);
+			Write(" ELSE ");
+			VisitValue(c.IfTrue);
+			Write(" END)");
+		}
+
+		return c;
+	}
+
+	protected override Expression VisitRowNumber(RowNumberExpression rowNumber)
+	{
+		Write("ROW_NUMBER() OVER(");
+
+		if (rowNumber.OrderBy is not null && rowNumber.OrderBy.Any())
+		{
+			Write("ORDER BY ");
+
+			for (var i = 0; i < rowNumber.OrderBy.Count; i++)
+			{
+				var exp = rowNumber.OrderBy[i];
+
+				if (i > 0)
+					Write(", ");
+
+				VisitValue(exp.Expression);
+
+				if (exp.OrderType != OrderType.Ascending)
+					Write(" DESC");
+			}
+		}
+
+		Write(")");
+
+		return rowNumber;
+	}
+
+	protected override Expression VisitIf(IfCommandExpression ifx)
+	{
+		if (!Language.AllowsMultipleCommands)
+			return base.VisitIf(ifx);
+
+		Write("IF ");
+		Visit(ifx.Check);
+		WriteLine(Indentation.Same);
+		Write("BEGIN");
+		WriteLine(Indentation.Inner);
+		VisitStatement(ifx.IfTrue);
+		WriteLine(Indentation.Outer);
+
+		if (ifx.IfFalse is not null)
+		{
+			Write("END ELSE BEGIN");
+			WriteLine(Indentation.Inner);
+			VisitStatement(ifx.IfFalse);
+			WriteLine(Indentation.Outer);
+		}
+
+		Write("END");
+
+		return ifx;
+	}
+
+	protected override Expression VisitBlock(Expressions.BlockExpression block)
+	{
+		if (!Language.AllowsMultipleCommands)
+			return base.VisitBlock(block);
+
+		for (var i = 0; i < block.Commands.Count; i++)
+		{
+			if (i > 0)
+			{
+				WriteLine(Indentation.Same);
+				WriteLine(Indentation.Same);
+			}
+
+			VisitStatement(block.Commands[i]);
+		}
+
+		return block;
+	}
+
+	protected override Expression VisitDeclaration(DeclarationExpression decl)
+	{
+		if (!Language.AllowsMultipleCommands)
+			return base.VisitDeclaration(decl);
+
+		for (var i = 0; i < decl.Variables.Count; i++)
+		{
+			var v = decl.Variables[i];
+
+			if (i > 0)
+				WriteLine(Indentation.Same);
+
+			Write("DECLARE @");
+			Write(v.Name);
+			Write(" ");
+			Write(Language.TypeSystem.Format(v.DataType, false));
+		}
+
+		if (decl.Source is not null)
+		{
+			WriteLine(Indentation.Same);
+			Write("SELECT ");
+
+			for (var i = 0; i < decl.Variables.Count; i++)
+			{
+				if (i > 0)
+					Write(", ");
+
+				Write("@");
+				Write(decl.Variables[i].Name);
+				Write(" = ");
+				Visit(decl.Source.Columns[i].Expression);
+			}
+
+			if (decl.Source.From is not null)
+			{
+				WriteLine(Indentation.Same);
+				Write("FROM ");
+				VisitSource(decl.Source.From);
+			}
+
+			if (decl.Source.Where is not null)
+			{
+				WriteLine(Indentation.Same);
+				Write("WHERE ");
+				Visit(decl.Source.Where);
+			}
+		}
+		else
+		{
+			for (var i = 0; i < decl.Variables.Count; i++)
+			{
+				var v = decl.Variables[i];
+
+				if (v.Expression is not null)
+				{
+					WriteLine(Indentation.Same);
+					Write("SET @");
+					Write(v.Name);
+					Write(" = ");
+					Visit(v.Expression);
+				}
+			}
+		}
+
+		return decl;
+	}
+}

src/Connected.ServiceModel.Client.Data/CqlLanguage.cs

@@ -0,0 +1,47 @@
+using Connected.Expressions;
+using Connected.Expressions.Languages;
+using Connected.Expressions.Translation;
+using Connected.Expressions.TypeSystem;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class CqlLanguage : QueryLanguage
+{
+	private static CqlLanguage? _default;
+
+	static CqlLanguage()
+	{
+		SplitChars = new char[] { '.' };
+	}
+
+	public CqlLanguage()
+	{
+		TypeSystem = new CqlTypeSystem();
+	}
+
+	public override QueryTypeSystem TypeSystem { get; }
+	private static char[] SplitChars { get; }
+	public override bool AllowsMultipleCommands => true;
+	public override bool AllowSubqueryInSelectWithoutFrom => true;
+	public override bool AllowDistinctInAggregates => true;
+
+	public static CqlLanguage Default
+	{
+		get
+		{
+			if (_default is null)
+				Interlocked.CompareExchange(ref _default, new CqlLanguage(), null);
+
+			return _default;
+		}
+	}
+
+	public override string Quote(string name)
+	{
+		return name;
+	}
+
+	public override Linguist CreateLinguist(ExpressionCompilationContext context, Translator translator)
+	{
+		return new CqlLinguist(context, this, translator);
+	}
+}

src/Connected.ServiceModel.Client.Data/CqlLinguist.cs

@@ -0,0 +1,41 @@
+using System.Linq.Expressions;
+using Connected.Expressions;
+using Connected.Expressions.Languages;
+using Connected.Expressions.Translation;
+using Connected.Expressions.Translation.Rewriters;
+
+namespace Connected.ServiceModel.Client.Data;
+
+internal class CqlLinguist : Linguist
+{
+
+	public CqlLinguist(ExpressionCompilationContext context, CqlLanguage language, Translator translator)
+		 : base(context, language, translator)
+	{
+	}
+
+	public override Expression Translate(Expression expression)
+	{
+		/*
+	    * fix up any order-by's
+	    */
+		expression = OrderByRewriter.Rewrite(Language, expression);
+
+		expression = base.Translate(expression);
+		/*
+	    * convert skip/take info into RowNumber pattern
+	    */
+		expression = SkipToRowNumberRewriter.Rewrite(Language, expression);
+		/*
+	    * fix up any order-by's we may have changed
+	    */
+		expression = OrderByRewriter.Rewrite(Language, expression);
+
+		return expression;
+	}
+
+	public override string Format(Expression expression)
+	{
+		return CqlFormatter.Format(Context, expression, Language);
+	}
+}

src/Connected.ServiceModel.Client.Data/CqlTypeSystem.cs

@@ -0,0 +1,190 @@
+using Connected.Expressions.Languages;
+using Connected.Expressions.TypeSystem;
+using Connected.Interop;
+using System.Data;
+using System.Globalization;
+using System.Reflection;
+using System.Text;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class CqlTypeSystem : QueryTypeSystem
+{
+	public static int StringDefaultSize => int.MaxValue;
+	public static int BinaryDefaultSize => int.MaxValue;
+
+	public override DataType Parse(string typeDeclaration)
+	{
+		string[]? args = null;
+		string typeName;
+		string? remainder = null;
+		var openParen = typeDeclaration.IndexOf('(');
+
+		if (openParen >= 0)
+		{
+			typeName = typeDeclaration[..openParen].Trim();
+
+			var closeParen = typeDeclaration.IndexOf(')', openParen);
+
+			if (closeParen < openParen)
+				closeParen = typeDeclaration.Length;
+
+			var argstr = typeDeclaration[(openParen + 1)..closeParen];
+
+			args = argstr.Split(',');
+
+			remainder = typeDeclaration[(closeParen + 1)..];
+		}
+		else
+		{
+			var space = typeDeclaration.IndexOf(' ');
+
+			if (space >= 0)
+			{
+				typeName = typeDeclaration[..space];
+				remainder = typeDeclaration[(space + 1)..].Trim();
+			}
+			else
+				typeName = typeDeclaration;
+		}
+
+		var isNotNull = (remainder is not null) && remainder.ToUpper().Contains("NOT NULL");
+
+		return ResolveDataType(typeName, args, isNotNull);
+	}
+
+	public DataType ResolveDataType(string typeName, string[] args, bool isNotNull)
+	{
+		if (string.Equals(typeName, "rowversion", StringComparison.OrdinalIgnoreCase))
+			typeName = "Timestamp";
+
+		if (string.Equals(typeName, "numeric", StringComparison.OrdinalIgnoreCase))
+			typeName = "Decimal";
+
+		if (string.Equals(typeName, "sql_variant", StringComparison.OrdinalIgnoreCase))
+			typeName = "Variant";
+
+		var dbType = ResolveSqlType(typeName);
+		var length = 0;
+		short precision = 0;
+		short scale = 0;
+
+		switch (dbType)
+		{
+			case SqlDbType.Binary:
+			case SqlDbType.Char:
+			case SqlDbType.Image:
+			case SqlDbType.NChar:
+			case SqlDbType.NVarChar:
+			case SqlDbType.VarBinary:
+			case SqlDbType.VarChar:
+				length = args is null || !args.Any() ? 32 : string.Equals(args[0], "max", StringComparison.OrdinalIgnoreCase) ? int.MaxValue : int.Parse(args[0]);
+				break;
+			case SqlDbType.Money:
+				precision = args is null || !args.Any() ? (short)29 : short.Parse(args[0], NumberFormatInfo.InvariantInfo);
+				scale = args is null || args.Length < 2 ? (short)4 : short.Parse(args[1], NumberFormatInfo.InvariantInfo);
+				break;
+			case SqlDbType.Decimal:
+				precision = args is null || !args.Any() ? (short)29 : short.Parse(args[0], NumberFormatInfo.InvariantInfo);
+				scale = args is null || args.Length < 2 ? (short)0 : short.Parse(args[1], NumberFormatInfo.InvariantInfo);
+				break;
+			case SqlDbType.Float:
+			case SqlDbType.Real:
+				precision = args is null || !args.Any() ? (short)29 : short.Parse(args[0], NumberFormatInfo.InvariantInfo);
+				break;
+		}
+
+		return NewType(dbType, isNotNull, length, precision, scale);
+	}
+
+	private static DataType NewType(SqlDbType type, bool isNotNull, int length, short precision, short scale)
+	{
+		return new CqlDataType(type, isNotNull, length, precision, scale);
+	}
+
+	public static SqlDbType ResolveSqlType(string typeName)
+	{
+		return (SqlDbType)Enum.Parse(typeof(SqlDbType), typeName, true);
+	}
+
+	public override DataType ResolveColumnType(Type type)
+	{
+		var isNotNull = type.GetTypeInfo().IsValueType && !Nullables.IsNullableType(type);
+		type = Nullables.GetNonNullableType(type);
+
+		switch (Interop.TypeSystem.GetTypeCode(type))
+		{
+			case TypeCode.Boolean:
+				return NewType(SqlDbType.Bit, isNotNull, 0, 0, 0);
+			case TypeCode.SByte:
+			case TypeCode.Byte:
+				return NewType(SqlDbType.TinyInt, isNotNull, 0, 0, 0);
+			case TypeCode.Int16:
+			case TypeCode.UInt16:
+				return NewType(SqlDbType.SmallInt, isNotNull, 0, 0, 0);
+			case TypeCode.Int32:
+			case TypeCode.UInt32:
+				return NewType(SqlDbType.Int, isNotNull, 0, 0, 0);
+			case TypeCode.Int64:
+			case TypeCode.UInt64:
+				return NewType(SqlDbType.BigInt, isNotNull, 0, 0, 0);
+			case TypeCode.Single:
+			case TypeCode.Double:
+				return NewType(SqlDbType.Float, isNotNull, 0, 0, 0);
+			case TypeCode.String:
+				return NewType(SqlDbType.NVarChar, isNotNull, StringDefaultSize, 0, 0);
+			case TypeCode.Char:
+				return NewType(SqlDbType.NChar, isNotNull, 1, 0, 0);
+			case TypeCode.DateTime:
+				return NewType(SqlDbType.DateTime, isNotNull, 0, 0, 0);
+			case TypeCode.Decimal:
+				return NewType(SqlDbType.Decimal, isNotNull, 0, 29, 4);
+			default:
+				if (type == typeof(byte[]))
+					return NewType(SqlDbType.VarBinary, isNotNull, BinaryDefaultSize, 0, 0);
+				else if (type == typeof(Guid))
+					return NewType(SqlDbType.UniqueIdentifier, isNotNull, 0, 0, 0);
+				else if (type == typeof(DateTimeOffset))
+					return NewType(SqlDbType.DateTimeOffset, isNotNull, 0, 0, 0);
+				else if (type == typeof(TimeSpan))
+					return NewType(SqlDbType.Time, isNotNull, 0, 0, 0);
+				else if (type.GetTypeInfo().IsEnum)
+					return NewType(SqlDbType.Int, isNotNull, 0, 0, 0);
+				else
+					throw new NotSupportedException(nameof(ResolveColumnType));
+		}
+	}
+
+	public static bool IsVariableLength(SqlDbType dbType)
+	{
+		return dbType switch
+		{
+			SqlDbType.Image or SqlDbType.NText or SqlDbType.NVarChar or SqlDbType.Text or SqlDbType.VarBinary or SqlDbType.VarChar or SqlDbType.Xml => true,
+			_ => false,
+		};
+	}
+
+	public override string Format(DataType type, bool suppressSize)
+	{
+		var sqlType = (CqlDataType)type;
+		var sb = new StringBuilder();
+
+		sb.Append(sqlType.DbType.ToString().ToUpper());
+
+		if (sqlType.Length > 0 && !suppressSize)
+		{
+			if (sqlType.Length == int.MaxValue)
+				sb.Append("(max)");
+			else
+				sb.AppendFormat(NumberFormatInfo.InvariantInfo, "({0})", sqlType.Length);
+		}
+		else if (sqlType.Precision != 0)
+		{
+			if (sqlType.Scale != 0)
+				sb.AppendFormat(NumberFormatInfo.InvariantInfo, "({0},{1})", sqlType.Precision, sqlType.Scale);
+			else
+				sb.AppendFormat(NumberFormatInfo.InvariantInfo, "({0})", sqlType.Precision);
+		}
+
+		return sb.ToString();
+	}
+}

src/Connected.ServiceModel.Client.Data/DataParameterCollection.cs

@@ -0,0 +1,61 @@
+using System.Data;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class DataParameterCollection : List<IDbDataParameter>, IDataParameterCollection
+{
+	public object this[string parameterName]
+	{
+		get
+		{
+			foreach (var parameter in this)
+			{
+				if (string.Equals(parameter.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase))
+					return parameter;
+			}
+
+			throw new NullReferenceException(nameof(IDbDataParameter));
+		}
+		set
+		{
+			if (value is not IDbDataParameter parameter)
+				throw new InvalidCastException(nameof(IDbDataParameter));
+
+			var idx = IndexOf(parameterName);
+
+			if (idx < 0)
+				throw new NullReferenceException(nameof(IDbDataParameter));
+
+			this[idx] = parameter;
+		}
+	}
+
+	public bool Contains(string parameterName)
+	{
+		foreach (var parameter in this)
+		{
+			if (string.Equals(parameter.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase))
+				return true;
+		}
+
+		return false;
+	}
+
+	public int IndexOf(string parameterName)
+	{
+		for (var i = 0; i < Count; i++)
+		{
+			var current = this[i];
+
+			if (string.Equals(current.ParameterName, parameterName, StringComparison.OrdinalIgnoreCase))
+				return i;
+		}
+
+		return -1;
+	}
+
+	public void RemoveAt(string parameterName)
+	{
+		if (this[parameterName] is IDbDataParameter target)
+			Remove(target);
+	}
+}

src/Connected.ServiceModel.Client.Data/DeleteCommandBuilder.cs

@@ -0,0 +1,56 @@
+using System.Collections.Concurrent;
+using System.Reflection;
+using Connected.Entities.Annotations;
+using Connected.Entities.Storage;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class DeleteCommandBuilder : CommandBuilder
+{
+	private static readonly ConcurrentDictionary<string, StorageOperation> _cache;
+
+	static DeleteCommandBuilder()
+	{
+		_cache = new();
+	}
+
+	private static ConcurrentDictionary<string, StorageOperation> Cache => _cache;
+
+	protected override StorageOperation OnBuild()
+	{
+		WriteLine($"DELETE [{Schema.Schema}].[{Schema.Name}] (");
+		WriteWhere();
+
+		var result = new StorageOperation { CommandText = CommandText };
+
+		foreach (var parameter in Parameters)
+			result.AddParameter(parameter);
+
+		Cache.TryAdd(Entity.GetType().FullName, result);
+
+		return result;
+	}
+
+	private void WriteWhere()
+	{
+		Write("WHERE ");
+
+		foreach (var property in Properties)
+		{
+			if (property.GetCustomAttribute<PrimaryKeyAttribute>() is not null)
+			{
+				var columnName = ColumnName(property);
+
+				CreateParameter(property);
+
+				Write($"{ColumnName} = @{ColumnName}");
+			}
+		}
+
+		Write(";");
+	}
+
+	protected override bool TryGetExisting(out StorageOperation? result)
+	{
+		return Cache.TryGetValue(Entity.GetType().FullName, out result);
+	}
+}

src/Connected.ServiceModel.Client.Data/InsertCommandBuilder.cs

@@ -0,0 +1,67 @@
+using System.Collections.Concurrent;
+using System.Reflection;
+using Connected.Entities.Annotations;
+using Connected.Entities.Storage;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class InsertCommandBuilder : CommandBuilder
+{
+	private static readonly ConcurrentDictionary<string, StorageOperation> _cache;
+
+	static InsertCommandBuilder()
+	{
+		_cache = new();
+	}
+
+	private static ConcurrentDictionary<string, StorageOperation> Cache => _cache;
+
+	protected override StorageOperation OnBuild()
+	{
+		WriteLine($"INSERT [{Schema.Schema}].[{Schema.Name}] (");
+
+		WriteColumns();
+		WriteLine(")");
+		Write("VALUES (");
+		WriteValues();
+		WriteLine(");");
+
+		var result = new StorageOperation { CommandText = CommandText };
+
+		foreach (var parameter in Parameters)
+			result.AddParameter(parameter);
+
+		Cache.TryAdd(Entity.GetType().FullName, result);
+
+		return result;
+	}
+
+	private void WriteColumns()
+	{
+		foreach (var property in Properties)
+		{
+			CreateParameter(property);
+
+			Write($"{ColumnName(property)}, ");
+		}
+
+		Trim();
+	}
+
+	private void WriteValues()
+	{
+		foreach (var property in Properties)
+		{
+			if (property.GetCustomAttribute<PrimaryKeyAttribute>() is not null)
+				continue;
+
+			Write($"@{ColumnName(property)}, ");
+		}
+
+		Trim();
+	}
+
+	protected override bool TryGetExisting(out StorageOperation? result)
+	{
+		return Cache.TryGetValue(Entity.GetType().FullName, out result);
+	}
+}

src/Connected.ServiceModel.Client.Data/Remote/RemoteTableColumn.cs

@@ -0,0 +1,12 @@
+using System.ComponentModel.DataAnnotations;
+
+namespace Connected.ServiceModel.Client.Data.Remote;
+internal sealed class RemoteTableColumn
+{
+	[Required, MaxLength(128)]
+	public string Name { get; set; } = default!;
+	[Required, MaxLength(128)]
+	public string DataType { get; set; } = default!;
+	public bool IsPartitionKey { get; set; }
+	public bool IsPrimaryKey { get; set; }
+}

src/Connected.ServiceModel.Client.Data/Remote/RemoteTableService.cs

@@ -0,0 +1,112 @@
+using System.Collections.Immutable;
+using System.Text.Json.Nodes;
+using Connected.Net;
+using Connected.ServiceModel.Client.Net;
+using Connected.ServiceModel.Client.Subscription;
+
+namespace Connected.ServiceModel.Client.Data.Remote;
+
+internal sealed class RemoteTableService
+{
+	//TODO:load it from config or environment.
+	private const string AccessToken = "Temp";
+	public RemoteTableService(IHttpService http, IConnectedServer server, ISubscriptionService subscription)
+	{
+		Http = http;
+		Server = server;
+		Subscription = subscription;
+	}
+
+	private IHttpService Http { get; }
+	private IConnectedServer Server { get; }
+	private ISubscriptionService Subscription { get; }
+	private int SubscriptionId { get; set; }
+
+	public async Task<JsonArray> Query(string commandText)
+	{
+		await Initialize();
+
+		var url = await Server.SelectUrl(new ConnectedServerUrlArgs { Kind = ConnectedUrlKind.TableStorage });
+
+		if (await Http.Post<JsonArray>($"{url}/query", new QueryTableArgs
+		{
+			CommandText = commandText,
+			AccessToken = AccessToken,
+			Subscription = SubscriptionId
+		}) is not JsonArray result)
+			return new JsonArray();
+
+		return result;
+	}
+
+	public async Task<ImmutableList<RemoteTableColumn>> QueryColumns(string tableName)
+	{
+		await Initialize();
+
+		var url = await Server.SelectUrl(new ConnectedServerUrlArgs { Kind = ConnectedUrlKind.TableStorage });
+
+		if (await Http.Post<List<RemoteTableColumn>>($"{url}/queryColumns", new TableSchemaArgs
+		{
+			TableName = tableName,
+			AccessToken = AccessToken,
+			Subscription = SubscriptionId
+		}) is not List<RemoteTableColumn> result)
+			return ImmutableList<RemoteTableColumn>.Empty;
+
+		return result.ToImmutableList();
+	}
+
+	public async Task<bool> TableExists(string tableName)
+	{
+		await Initialize();
+
+		var url = await Server.SelectUrl(new ConnectedServerUrlArgs { Kind = ConnectedUrlKind.TableStorage });
+
+		return await Http.Post<bool>($"{url}/tableExists", new TableSchemaArgs
+		{
+			TableName = tableName,
+			AccessToken = AccessToken,
+			Subscription = SubscriptionId
+		});
+	}
+
+	public async Task Update(string commandText)
+	{
+		await Initialize();
+
+		var url = await Server.SelectUrl(new ConnectedServerUrlArgs { Kind = ConnectedUrlKind.TableStorage });
+
+		await Http.Post($"{url}/update", new UpdateTableArgs
+		{
+			CommandText = commandText,
+			AccessToken = AccessToken,
+			Subscription = SubscriptionId
+		});
+	}
+
+	public async Task CreateTable(string tableName, List<RemoteTableColumn> columns)
+	{
+		await Initialize();
+
+		var url = await Server.SelectUrl(new ConnectedServerUrlArgs { Kind = ConnectedUrlKind.TableStorage });
+
+		await Http.Post($"{url}/createTable", new CreateTableArgs
+		{
+			Name = tableName,
+			Columns = columns,
+			AccessToken = AccessToken,
+			Subscription = SubscriptionId
+		});
+	}
+
+	private async Task Initialize()
+	{
+		if (SubscriptionId > 0)
+			return;
+
+		if (await Subscription.Select() is not ISubscription subscription)
+			throw new NullReferenceException(nameof(ISubscription));
+
+		SubscriptionId = subscription.Id;
+	}
+}

src/Connected.ServiceModel.Client.Data/Remote/TableArgs.cs

@@ -0,0 +1,33 @@
+using System.ComponentModel.DataAnnotations;
+using Connected.Annotations;
+
+namespace Connected.ServiceModel.Client.Data.Remote;
+internal class TableArgs : ServiceArgs
+{
+}
+
+internal sealed class QueryTableArgs : TableArgs
+{
+	[Required]
+	public string CommandText { get; set; } = default!;
+}
+
+internal sealed class TableSchemaArgs : ServiceArgs
+{
+	[Required, MaxLength(128)]
+	public string TableName { get; set; } = default!;
+}
+
+internal sealed class CreateTableArgs : ServiceArgs
+{
+	[Required, MaxLength(128)]
+	public string Name { get; set; } = default!;
+	[NonDefault]
+	public List<RemoteTableColumn> Columns { get; set; }
+}
+
+internal sealed class UpdateTableArgs : ServiceArgs
+{
+	[Required]
+	public string CommandText { get; set; } = default!;
+}

src/Connected.ServiceModel.Client.Data/Schema/ExistingSchema.cs

@@ -0,0 +1,45 @@
+using Connected.Data.Schema;
+
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal sealed class ExistingSchema : ISchema
+{
+	public ExistingSchema()
+	{
+		Columns = new();
+	}
+
+	public List<ISchemaColumn> Columns { get; }
+
+	public string? Schema => null;
+
+	public string? Name { get; set; }
+
+	public string? Type { get; set; }
+
+	public bool Ignore { get; set; }
+
+	public async Task Load(SchemaExecutionContext context)
+	{
+		Name = context.Schema.Name;
+		Type = context.Schema.Type;
+
+		if (!await context.Remote.TableExists(context.Schema.Name))
+			return;
+
+		var columns = await context.Remote.QueryColumns(context.Schema.Name);
+
+		foreach (var column in columns)
+		{
+			Columns.Add(new SchemaColumn
+			{
+				Name = column.Name,
+				//TODO:populate properties
+			});
+		}
+	}
+
+	public bool Equals(ISchema? other)
+	{
+		throw new NotImplementedException();
+	}
+}

src/Connected.ServiceModel.Client.Data/Schema/SchemaColumn.cs

@@ -0,0 +1,43 @@
+using System.Data;
+using System.Reflection;
+using Connected.Data.Schema;
+using Connected.Entities.Annotations;
+
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal sealed class SchemaColumn : ISchemaColumn
+{
+	public string? Name { get; set; }
+
+	public DbType DataType { get; set; }
+
+	public bool IsIdentity { get; set; }
+
+	public bool IsUnique { get; set; }
+
+	public bool IsIndex { get; set; }
+
+	public bool IsPrimaryKey { get; set; }
+
+	public bool IsVersion { get; set; }
+
+	public string? DefaultValue { get; set; }
+
+	public int MaxLength { get; set; }
+
+	public bool IsNullable { get; set; }
+
+	public string? Index { get; set; }
+
+	public int Scale { get; set; }
+
+	public int Precision { get; set; }
+
+	public DateKind DateKind { get; set; }
+
+	public BinaryKind BinaryKind { get; set; }
+
+	public int DatePrecision { get; set; }
+
+	public bool IsPartitionKey { get; set; }
+	public PropertyInfo Property { get; set; }
+}

src/Connected.ServiceModel.Client.Data/Schema/SchemaExecutionContext.cs

@@ -0,0 +1,16 @@
+using Connected.Data.Schema;
+using Connected.ServiceModel.Client.Data.Remote;
+
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal sealed class SchemaExecutionContext
+{
+	public SchemaExecutionContext(ISchema schema, RemoteTableService remote)
+	{
+		Schema = schema;
+		Remote = remote;
+	}
+
+	public ExistingSchema ExistingSchema { get; set; }
+	public ISchema Schema { get; }
+	public RemoteTableService Remote { get; }
+}

src/Connected.ServiceModel.Client.Data/Schema/SynchronizationCommand.cs

@@ -0,0 +1,4 @@
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal class SynchronizationCommand
+{
+}

src/Connected.ServiceModel.Client.Data/Schema/SynchronizationQuery.cs

@@ -0,0 +1,19 @@
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal class SynchronizationQuery<T> : SynchronizationCommand
+{
+	protected SchemaExecutionContext Context { get; private set; }
+
+	public async Task<T> Execute(SchemaExecutionContext context)
+	{
+		Context = context;
+
+		return await OnExecute();
+	}
+
+	protected virtual async Task<T> OnExecute()
+	{
+		await Task.CompletedTask;
+
+		return default;
+	}
+}

src/Connected.ServiceModel.Client.Data/Schema/SynchronizationTransaction.cs

@@ -0,0 +1,17 @@
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal class SynchronizationTransaction : SynchronizationCommand
+{
+	protected SchemaExecutionContext Context { get; private set; }
+
+	public async Task Execute(SchemaExecutionContext context)
+	{
+		Context = context;
+
+		await OnExecute();
+	}
+
+	protected virtual async Task OnExecute()
+	{
+		await Task.CompletedTask;
+	}
+}

src/Connected.ServiceModel.Client.Data/Schema/TableCreate.cs

@@ -0,0 +1,127 @@
+using Connected.Collections;
+using Connected.Interop;
+using Connected.ServiceModel.Annotations;
+using Connected.ServiceModel.Client.Data.Remote;
+
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal sealed class TableCreate : TableTransaction
+{
+	//private const string KeysExceptionMessage = "A ISchemaColumn cannot have a PartitionKeyAttribute and PrimaryKeyAttribute set. Use either PartitionKey or PrimaryKey attribute.";
+	//private const string NoPartitionKeyMessage = "Schema must have at least one property with PartitionKeyAttribute.";
+
+	protected override async Task OnExecute()
+	{
+		var columns = new List<RemoteTableColumn>();
+
+		Context.Schema.Columns.SortByOrdinal();
+
+		foreach (var column in Context.Schema.Columns)
+		{
+			columns.Add(new RemoteTableColumn
+			{
+				DataType = CreateDataTypeMetaData(column),
+				IsPartitionKey = column.Property?.FindAttribute<PartitionKeyAttribute>() is not null,
+				IsPrimaryKey = column.IsPrimaryKey,
+				Name = column.Name
+			});
+		}
+
+		await Context.Remote.CreateTable(Context.Schema.Name, columns);
+	}
+
+	//private List<ISchemaColumn> PartitionKeys
+	//{
+	//	get
+	//	{
+	//		var result = new List<ISchemaColumn>();
+
+	//		foreach (var column in Context.Schema.Columns)
+	//		{
+	//			if (column.Property?.FindAttribute<PartitionKeyAttribute>() is not null)
+	//			{
+	//				if (column.IsPrimaryKey)
+	//					throw new InvalidOperationException($"{KeysExceptionMessage} ({column.Name})");
+
+	//				result.Add(column);
+	//			}
+	//		}
+
+	//		return result;
+	//	}
+	//}
+
+	//private List<ISchemaColumn> PrimaryKeys
+	//{
+	//	get
+	//	{
+	//		var result = new List<ISchemaColumn>();
+
+	//		foreach (var column in Context.Schema.Columns)
+	//		{
+	//			if (column.IsPrimaryKey)
+	//			{
+	//				if (column.Property?.FindAttribute<PartitionKeyAttribute>() is not null)
+	//					throw new InvalidOperationException($"{KeysExceptionMessage} ({column.Name})");
+
+	//				result.Add(column);
+	//			}
+	//		}
+
+	//		return result;
+	//	}
+	//}
+
+	//private string CommandText
+	//{
+	//	get
+	//	{
+	//		var partitionKeys = PartitionKeys;
+	//		var primaryKeys = PrimaryKeys;
+
+	//		if (!partitionKeys.Any())
+	//			throw new InvalidOperationException($"{NoPartitionKeyMessage} ({Context.Schema.Name})");
+
+	//		var keysCount = partitionKeys.Count + primaryKeys.Count;
+	//		var text = new StringBuilder();
+	//		var name = Temporary ? TemporaryName : Context.Schema.Name;
+
+	//		text.AppendLine($"CREATE TABLE {name}");
+	//		text.AppendLine("(");
+	//		var comma = string.Empty;
+
+	//		for (var i = 0; i < Context.Schema.Columns.Count; i++)
+	//		{
+	//			text.AppendLine($"{comma} {CreateColumnCommandText(Context.Schema.Columns[i])}");
+
+	//			comma = ",";
+	//		}
+
+	//		text.Append("PRIMARY KEY (");
+
+	//		if (keysCount > 1)
+	//			text.Append('(');
+
+	//		for (var i = 0; i < partitionKeys.Count; i++)
+	//		{
+	//			text.Append(partitionKeys[i].Name);
+
+	//			if (i < partitionKeys.Count - 1)
+	//				text.Append(',');
+	//		}
+
+	//		if (keysCount > 1)
+	//			text.Append(')');
+
+	//		for (var i = 0; i < primaryKeys.Count; i++)
+	//		{
+	//			text.Append(primaryKeys[i].Name);
+
+	//			if (i < primaryKeys.Count - 1)
+	//				text.Append(',');
+	//		}
+
+	//		text.AppendLine(");");
+
+	//		return text.ToString();
+	//	}
+}

src/Connected.ServiceModel.Client.Data/Schema/TableExists.cs

@@ -0,0 +1,8 @@
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal class TableExists : SynchronizationQuery<bool>
+{
+	protected override async Task<bool> OnExecute()
+	{
+		return await Context.Remote.TableExists(Context.Schema.Name);
+	}
+}

src/Connected.ServiceModel.Client.Data/Schema/TableSynchronize.cs

@@ -0,0 +1,93 @@
+using Connected.Data.Schema;
+
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal sealed class TableSynchronize : TableTransaction
+{
+	private ExistingSchema? _existingSchema;
+
+	private bool TableExists { get; set; }
+
+	protected override async Task OnExecute()
+	{
+		TableExists = await new TableExists().Execute(Context);
+
+		if (!TableExists)
+		{
+			await new TableCreate().Execute(Context);
+			return;
+		}
+
+		return;
+
+		_existingSchema = new();
+
+		await _existingSchema.Load(Context);
+
+		Context.ExistingSchema = ExistingSchema;
+
+		//TODO: implement alter table
+
+		//if (ShouldRecreate)
+		//	await new TableRecreate(ExistingSchema).Execute(Context);
+		//else if (ShouldAlter)
+		//	await new TableAlter(ExistingSchema).Execute(Context);
+	}
+
+	private bool ShouldAlter => !Context.Schema.Equals(ExistingSchema);
+	private bool ShouldRecreate => HasIdentityChanged || HasColumnMetadataChanged;
+
+	private ExistingSchema? ExistingSchema => _existingSchema;
+
+	private bool HasIdentityChanged
+	{
+		get
+		{
+			foreach (var column in Context.Schema.Columns)
+			{
+				if (ExistingSchema.Columns.FirstOrDefault(f => string.Equals(f.Name, column.Name, StringComparison.OrdinalIgnoreCase)) is not ISchemaColumn existing)
+					return true;
+
+				if (existing.IsIdentity != column.IsIdentity)
+					return true;
+			}
+
+			foreach (var existing in ExistingSchema.Columns)
+			{
+				var column = Context.Schema.Columns.FirstOrDefault(f => string.Equals(f.Name, existing.Name, StringComparison.OrdinalIgnoreCase));
+
+				if (column is null && existing.IsIdentity)
+					return true;
+				else if (column is not null && column.IsIdentity != existing.IsIdentity)
+					return true;
+			}
+
+			return false;
+		}
+	}
+
+	private bool HasColumnMetadataChanged
+	{
+		get
+		{
+			foreach (var existing in ExistingSchema.Columns)
+			{
+				if (Context.Schema.Columns.FirstOrDefault(f => string.Equals(f.Name, existing.Name, StringComparison.OrdinalIgnoreCase)) is not ISchemaColumn column)
+					continue;
+
+				if (column.DataType != existing.DataType
+					|| column.MaxLength != existing.MaxLength
+					|| column.IsNullable != existing.IsNullable
+					|| column.IsVersion != existing.IsVersion
+					|| column.Precision != existing.Precision
+					|| column.Scale != existing.Scale
+					|| column.DateKind != existing.DateKind
+					|| column.BinaryKind != existing.BinaryKind
+					|| column.DatePrecision != existing.DatePrecision)
+					return true;
+			}
+
+			return false;
+		}
+	}
+}
+

src/Connected.ServiceModel.Client.Data/Schema/TableTransaction.cs

@@ -0,0 +1,51 @@
+using System.Data;
+using System.Text;
+using Connected.Data.Schema;
+
+namespace Connected.ServiceModel.Client.Data.Schema;
+internal class TableTransaction : SynchronizationTransaction
+{
+	protected static string CreateColumnCommandText(ISchemaColumn column)
+	{
+		var builder = new StringBuilder();
+
+		builder.AppendFormat($"{column.Name} {CreateDataTypeMetaData(column)} ");
+
+		return builder.ToString();
+	}
+
+	protected static string CreateDataTypeMetaData(ISchemaColumn column)
+	{
+		return column.DataType switch
+		{
+			DbType.AnsiString => "text",
+			DbType.Binary => "blob",
+			DbType.Byte => "tinyint",
+			DbType.Boolean => "boolean",
+			DbType.Currency => "decimal",
+			DbType.Date => "timestamp",
+			DbType.DateTime => "timestamp",
+			DbType.Decimal => "decimal",
+			DbType.Double => "double",
+			DbType.Guid => "uuid",
+			DbType.Int16 => "smallint",
+			DbType.Int32 => "int",
+			DbType.Int64 => "bigint",
+			DbType.Object => "blob",
+			DbType.SByte => "smallint",
+			DbType.Single => "float",
+			DbType.String => "text",
+			DbType.Time => "time",
+			DbType.UInt16 => "int",
+			DbType.UInt32 => "bigint",
+			DbType.UInt64 => "float",
+			DbType.VarNumeric => "decimal",
+			DbType.AnsiStringFixedLength => "text",
+			DbType.StringFixedLength => "text",
+			DbType.Xml => "text",
+			DbType.DateTime2 => "timestamp",
+			DbType.DateTimeOffset => "timestamp",
+			_ => throw new NotSupportedException(),
+		};
+	}
+}

src/Connected.ServiceModel.Client.Data/TableCommand.cs

@@ -0,0 +1,68 @@
+using Connected.Data.Storage;
+using Connected.Entities.Storage;
+
+namespace Connected.ServiceModel.Client.Data;
+
+internal abstract class TableCommand : IStorageCommand
+{
+	protected TableCommand(IStorageOperation operation, IStorageConnection connection)
+	{
+		Connection = connection;
+		Operation = operation;
+	}
+
+	protected bool IsDisposed { get; private set; }
+	public IStorageOperation Operation { get; }
+	public IStorageConnection? Connection { get; protected set; }
+
+	protected virtual async ValueTask DisposeAsync(bool disposing)
+	{
+		if (!IsDisposed)
+		{
+			if (disposing)
+			{
+				Connection = null;
+
+				await OnDisposingAsync();
+			}
+
+			IsDisposed = true;
+		}
+	}
+
+	protected virtual async ValueTask OnDisposingAsync()
+	{
+		await ValueTask.CompletedTask;
+	}
+
+	protected virtual void OnDisposing()
+	{
+	}
+
+	public async ValueTask DisposeAsync()
+	{
+		await DisposeAsync(true);
+		GC.SuppressFinalize(this);
+	}
+
+	protected virtual void Dispose(bool disposing)
+	{
+		if (!IsDisposed)
+		{
+			if (disposing)
+			{
+				Connection = null;
+
+				OnDisposing();
+			}
+
+			IsDisposed = true;
+		}
+	}
+
+	public void Dispose()
+	{
+		Dispose(true);
+		GC.SuppressFinalize(this);
+	}
+}

src/Connected.ServiceModel.Client.Data/TableConnection.cs

@@ -0,0 +1,85 @@
+using System.Data;
+using Connected.ServiceModel.Client.Data.Remote;
+
+namespace Connected.ServiceModel.Client.Data;
+/// <summary>
+/// Represents the REST connection to the TomPIT.connected Table Service.
+/// </summary>
+internal sealed class TableConnection : IDbConnection
+{
+	public TableConnection(RemoteTableService tables, string connectionString)
+	{
+		Tables = tables;
+		ConnectionString = connectionString;
+	}
+
+	public RemoteTableService Tables { get; }
+
+	/// <summary>
+	/// The connection string (URL) used when performing the requests. 
+	/// </summary>
+	public string ConnectionString { get; set; }
+	/// <summary>
+	/// The request timeout in seconds.
+	/// </summary>
+	public int ConnectionTimeout => 120;
+	/// <summary>
+	/// The database (partition) on the server to be used.
+	/// </summary>
+	public string Database { get; private set; }
+	/// <summary>
+	/// The connection state. It's always open since it's a stateless connection.
+	/// </summary>
+	public ConnectionState State => ConnectionState.Open;
+	/// <summary>
+	/// Starts the new storage transaction.
+	/// </summary>
+	/// <returns>A new <see cref="IDbTransaction"/>.</returns>
+	public IDbTransaction BeginTransaction()
+	{
+		return new TableTransaction(this);
+	}
+	/// <summary>
+	/// Starts the new storage transaction.
+	/// </summary>
+	/// <param name="il">The isolation level. This property is ignored on this connection since 
+	/// it's always <see cref="IsolationLevel.Snapshot"/>.</param>
+	/// <returns>A new <see cref="IDbTransaction"/>.</returns>
+	public IDbTransaction BeginTransaction(IsolationLevel il)
+	{
+		return BeginTransaction();
+	}
+	/// <summary>
+	/// The database is actually the Partition on the remote service. Calling this method
+	/// changes the partition to be used on the remote.
+	/// </summary>
+	/// <param name="databaseName">The partition name. It is created if it doesn't exist.</param>
+	public void ChangeDatabase(string databaseName)
+	{
+		Database = databaseName;
+	}
+	/// <summary>
+	/// This method completes the connection by calling  <see cref="IDbTransaction.Rollback"/>
+	/// if <see cref="IDbTransaction.Commit"/> has not been called.
+	/// </summary>
+	public void Close()
+	{
+
+	}
+
+	public IDbCommand CreateCommand()
+	{
+		return new TableDataCommand(Tables);
+	}
+
+	public void Dispose()
+	{
+	}
+	/// <summary>
+	/// This method doesn't do anything since the connection is stateless any is theoretically
+	/// always in open state.
+	/// </summary>
+	public void Open()
+	{
+	}
+}

src/Connected.ServiceModel.Client.Data/TableDataCommand.cs

@@ -0,0 +1,64 @@
+using System.Data;
+using Connected.ServiceModel.Client.Data.Remote;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class TableDataCommand : IDbCommand
+{
+	public TableDataCommand(RemoteTableService tables)
+	{
+		Parameters = new DataParameterCollection();
+		Tables = tables;
+	}
+	public string CommandText { get; set; }
+	public int CommandTimeout { get; set; }
+	public CommandType CommandType { get; set; }
+	public IDbConnection? Connection { get; set; }
+
+	public IDataParameterCollection Parameters { get; }
+
+	public IDbTransaction? Transaction { get; set; }
+	public UpdateRowSource UpdatedRowSource { get; set; }
+	public RemoteTableService Tables { get; }
+
+	public void Cancel()
+	{
+
+	}
+
+	public IDbDataParameter CreateParameter()
+	{
+		return new TableDataParameter();
+	}
+
+	public void Dispose()
+	{
+
+	}
+
+	public int ExecuteNonQuery()
+	{
+		AsyncUtils.RunSync(() => Tables.Update(CommandText));
+
+		return 0;
+	}
+
+	public IDataReader ExecuteReader()
+	{
+		return new TableDataReader(AsyncUtils.RunSync(() => Tables.Query(CommandText)));
+	}
+
+	public IDataReader ExecuteReader(CommandBehavior behavior)
+	{
+		return new TableDataReader(AsyncUtils.RunSync(() => Tables.Query(CommandText)));
+	}
+
+	public object? ExecuteScalar()
+	{
+		throw new NotImplementedException();
+	}
+
+	public void Prepare()
+	{
+		throw new NotImplementedException();
+	}
+}

src/Connected.ServiceModel.Client.Data/TableDataConnection.cs

@@ -0,0 +1,62 @@
+using System.Data;
+using Connected.Annotations;
+using Connected.Data.Storage;
+using Connected.ServiceModel.Client.Data.Remote;
+using Microsoft.Data.SqlClient;
+
+namespace Connected.ServiceModel.Client.Data;
+
+[ServiceRegistration(ServiceRegistrationMode.Auto, ServiceRegistrationScope.Transient)]
+internal sealed class TableDataConnection : DatabaseConnection
+{
+	public TableDataConnection(RemoteTableService tables, ICancellationContext context) : base(context)
+	{
+		Tables = tables;
+	}
+	private RemoteTableService Tables { get; }
+
+	protected override void SetupParameters(IStorageCommand command, IDbCommand cmd)
+	{
+		if (cmd.Parameters.Count > 0)
+		{
+			foreach (SqlParameter i in cmd.Parameters)
+				i.Value = DBNull.Value;
+
+			return;
+		}
+
+		if (command.Operation.Parameters is null)
+			return;
+
+		foreach (var i in command.Operation.Parameters)
+		{
+			cmd.Parameters.Add(new SqlParameter
+			{
+				ParameterName = i.Name,
+				DbType = i.Type,
+				Direction = i.Direction
+			});
+		}
+	}
+
+	protected override object GetParameterValue(IDbCommand command, string parameterName)
+	{
+		if (command is SqlCommand cmd)
+			return cmd.Parameters[parameterName].Value;
+
+		return null;
+	}
+
+	protected override void SetParameterValue(IDbCommand command, string parameterName, object value)
+	{
+		if (command is SqlCommand cmd)
+			cmd.Parameters[parameterName].Value = value;
+	}
+
+	protected override async Task<IDbConnection> OnCreateConnection()
+	{
+		await Task.CompletedTask;
+
+		return new TableConnection(Tables, ConnectionString);
+	}
+}

src/Connected.ServiceModel.Client.Data/TableDataParameter.cs

@@ -0,0 +1,16 @@
+using System.Data;
+
+namespace Connected.ServiceModel.Client.Data;
+internal class TableDataParameter : IDbDataParameter
+{
+	public byte Precision { get; set; }
+	public byte Scale { get; set; }
+	public int Size { get; set; }
+	public DbType DbType { get; set; }
+	public ParameterDirection Direction { get; set; }
+	public bool IsNullable { get; set; }
+	public string ParameterName { get; set; }
+	public string SourceColumn { get; set; }
+	public DataRowVersion SourceVersion { get; set; }
+	public object? Value { get; set; }
+}

src/Connected.ServiceModel.Client.Data/TableDataReader.cs

@@ -0,0 +1,164 @@
+using System.Data;
+using System.Diagnostics.CodeAnalysis;
+using System.Text.Json.Nodes;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class TableDataReader : IDataReader
+{
+	public TableDataReader(JsonArray items)
+	{
+		Items = items;
+	}
+
+	public object this[int i] => throw new NotImplementedException();
+
+	public object this[string name] => throw new NotImplementedException();
+
+	public int Depth => throw new NotImplementedException();
+
+	public bool IsClosed => throw new NotImplementedException();
+
+	public int RecordsAffected => throw new NotImplementedException();
+
+	public int FieldCount => throw new NotImplementedException();
+
+	public JsonArray Items { get; }
+
+	public void Close()
+	{
+		throw new NotImplementedException();
+	}
+
+	public void Dispose()
+	{
+		throw new NotImplementedException();
+	}
+
+	public bool GetBoolean(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public byte GetByte(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public long GetBytes(int i, long fieldOffset, byte[]? buffer, int bufferoffset, int length)
+	{
+		throw new NotImplementedException();
+	}
+
+	public char GetChar(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public long GetChars(int i, long fieldoffset, char[]? buffer, int bufferoffset, int length)
+	{
+		throw new NotImplementedException();
+	}
+
+	public IDataReader GetData(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public string GetDataTypeName(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public DateTime GetDateTime(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public decimal GetDecimal(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public double GetDouble(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	[return: DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicFields | DynamicallyAccessedMemberTypes.PublicProperties)]
+	public Type GetFieldType(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public float GetFloat(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public Guid GetGuid(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public short GetInt16(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public int GetInt32(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public long GetInt64(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public string GetName(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public int GetOrdinal(string name)
+	{
+		throw new NotImplementedException();
+	}
+
+	public DataTable? GetSchemaTable()
+	{
+		throw new NotImplementedException();
+	}
+
+	public string GetString(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public object GetValue(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public int GetValues(object[] values)
+	{
+		throw new NotImplementedException();
+	}
+
+	public bool IsDBNull(int i)
+	{
+		throw new NotImplementedException();
+	}
+
+	public bool NextResult()
+	{
+		throw new NotImplementedException();
+	}
+
+	public bool Read()
+	{
+		//var items = AsyncUtils.RunSync(() => Service.Query(CommandText));
+
+		return false;
+	}
+}

src/Connected.ServiceModel.Client.Data/TableReader.cs

@@ -0,0 +1,74 @@
+using System.Collections.Immutable;
+using System.Data;
+using Connected.Data.Storage;
+using Connected.Entities.Storage;
+
+namespace Connected.ServiceModel.Client.Data;
+
+internal sealed class TableReader<T> : TableCommand, IStorageReader<T>
+{
+	public TableReader(IStorageOperation operation, IStorageConnection connection)
+		: base(operation, connection)
+	{
+	}
+
+	public async Task<ImmutableList<T>?> Query()
+	{
+		if (Connection is null)
+			return default;
+
+		try
+		{
+			var result = await Connection.Query<T>(this);
+
+			if (Connection.Behavior == StorageConnectionMode.Isolated)
+				await Connection.Commit();
+
+			return result;
+		}
+		finally
+		{
+			if (Connection.Behavior == StorageConnectionMode.Isolated)
+			{
+				await Connection.Close();
+				await Connection.DisposeAsync();
+
+				Connection = null;
+			}
+		}
+	}
+
+	public async Task<T?> Select()
+	{
+		try
+		{
+			if (Connection is null)
+				return default;
+
+			var result = await Connection.Select<T>(this);
+
+			if (Connection.Behavior == StorageConnectionMode.Isolated)
+				await Connection.Commit();
+
+			return result;
+		}
+		finally
+		{
+			if (Connection.Behavior == StorageConnectionMode.Isolated)
+			{
+				await Connection.Close();
+				await Connection.DisposeAsync();
+
+				Connection = null;
+			}
+		}
+	}
+
+	public async Task<IDataReader> OpenReader()
+	{
+		if (Connection is null)
+			return default;
+
+		return await Connection.OpenReader(this);
+	}
+}

src/Connected.ServiceModel.Client.Data/TableSchemaMiddleware.cs

@@ -0,0 +1,55 @@
+using Connected.Annotations;
+using Connected.Data.Schema;
+using Connected.Entities.Annotations;
+using Connected.Entities.Storage;
+using Connected.Interop;
+using Connected.Middleware;
+using Connected.ServiceModel.Client.Data.Remote;
+using Connected.ServiceModel.Client.Data.Schema;
+using Connected.ServiceModel.Client.Net;
+using Connected.ServiceModel.Data;
+
+namespace Connected.ServiceModel.Client.Data;
+
+[Priority(2)]
+internal sealed class TableSchemaMiddleware : MiddlewareComponent, ISchemaMiddleware
+{
+	public TableSchemaMiddleware(IMiddlewareService middleware, IStorageProvider storage, RemoteTableService remote, IConnectedServer connected)
+	{
+		Storage = storage;
+		Remote = remote;
+		Connected = connected;
+	}
+	private IStorageProvider Storage { get; }
+	private RemoteTableService Remote { get; }
+	private IConnectedServer Connected { get; }
+	public Type ConnectionType => typeof(TableDataConnection);
+	public string DefaultConnectionString { get; private set; } = default!;
+
+	protected override async Task OnInitialize()
+	{
+		DefaultConnectionString = await Connected.SelectUrl(new ConnectedServerUrlArgs { Kind = ConnectedUrlKind.TableStorage });
+	}
+
+	public async Task<bool> IsEntitySupported(Type entityType)
+	{
+		await Task.CompletedTask;
+		/*
+		 * This middleware supports all ITableEntity<> entities.
+		 */
+		return entityType.ImplementsInterface(typeof(ITableEntity<>));
+	}
+
+	public async Task Synchronize(Type entity, ISchema schema)
+	{
+		await Synchronize(schema, DefaultConnectionString);
+	}
+
+	private async Task Synchronize(ISchema schema, string connectionString)
+	{
+		var args = new SchemaExecutionContext(schema, Remote);
+
+		if (string.IsNullOrWhiteSpace(schema.Type) || string.Equals(schema.Type, SchemaAttribute.SchemaTypeTable, StringComparison.OrdinalIgnoreCase))
+			await new TableSynchronize().Execute(args);
+	}
+}

src/Connected.ServiceModel.Client.Data/TableStorageProvider.cs

@@ -0,0 +1,114 @@
+using System.Linq.Expressions;
+using System.Reflection;
+using Connected.Annotations;
+using Connected.Data;
+using Connected.Data.Storage;
+using Connected.Entities;
+using Connected.Entities.Storage;
+using Connected.Expressions;
+using Connected.Expressions.Evaluation;
+using Connected.Expressions.Query;
+using Connected.Expressions.Translation;
+using Connected.Interop;
+using Connected.ServiceModel.Data;
+
+namespace Connected.ServiceModel.Client.Data;
+
+[Priority(2)]
+internal class TableStorageProvider : QueryProvider, IStorageExecutor, IStorageMiddleware
+{
+	public TableStorageProvider(IStorageProvider storage)
+	{
+		Storage = storage;
+	}
+
+	private IStorageProvider Storage { get; }
+
+	protected override object? OnExecute(Expression expression)
+	{
+		return CreateExecutionPlan(expression).Compile()(this);
+	}
+
+	private static Expression<Func<IStorageExecutor, object>> CreateExecutionPlan(Expression expression)
+	{
+		var lambda = expression as LambdaExpression;
+
+		if (lambda is not null)
+			expression = lambda.Body;
+
+		var context = new ExpressionCompilationContext(new CqlLanguage());
+		var translator = new Translator(context);
+		var translation = translator.Translate(expression);
+		var parameters = lambda?.Parameters;
+		var provider = Resolve(expression, parameters, typeof(IStorage<>));
+
+		if (provider is null)
+		{
+			var rootQueryable = Resolve(expression, parameters, typeof(IQueryable));
+
+			provider = Expression.Property(rootQueryable, typeof(IQueryable).GetTypeInfo().GetDeclaredProperty(nameof(IQueryable.Provider)));
+		}
+
+		return ExecutionBuilder.Build(context, new CqlLinguist(context, CqlLanguage.Default, translator), translation, provider);
+	}
+
+	/// <summary>
+	/// Find the expression of the specified type, either in the specified expression or parameters.
+	/// </summary>
+	private static Expression Resolve(Expression expression, IList<ParameterExpression> parameters, Type type)
+	{
+		if (parameters is not null)
+		{
+			var found = parameters.FirstOrDefault(p => type.IsAssignableFrom(p.Type));
+
+			if (found is not null)
+				return found;
+		}
+
+		return SubtreeResolver.Resolve(expression, type);
+	}
+
+	public IEnumerable<TResult?> Execute<TResult>(IStorageOperation operation)
+		 where TResult : IEntity
+	{
+		var result = Storage.Open<TResult>().Query(new StorageContextArgs(operation));
+
+		if (result.IsCompleted)
+			return result.Result;
+
+		var r = result.GetAwaiter().GetResult();
+
+		return r;
+	}
+
+	public bool SupportsEntity(Type entityType)
+	{
+		return entityType.ImplementsInterface(typeof(ITableEntity<>));
+	}
+
+	public IStorageOperation CreateOperation<TEntity>(TEntity entity)
+		where TEntity : IEntity
+	{
+		var builder = new AggregatedCommandBuilder<TEntity?>();
+
+		if (builder.Build(entity) is not StorageOperation operation)
+			throw new NullReferenceException(nameof(StorageOperation));
+
+		return operation;
+	}
+
+	public IStorageReader<TEntity> OpenReader<TEntity>(IStorageOperation operation, IStorageConnection connection)
+	{
+		return new TableReader<TEntity>(operation, connection);
+	}
+
+	public IStorageWriter OpenWriter(IStorageOperation operation, IStorageConnection connection)
+	{
+		return new TableWriter(operation, connection);
+	}
+
+	public async Task Initialize()
+	{
+		await Task.CompletedTask;
+	}
+}

src/Connected.ServiceModel.Client.Data/TableTransaction.cs

@@ -0,0 +1,59 @@
+using System.Data;
+
+namespace Connected.ServiceModel.Client.Data;
+/// <summary>
+/// Defines the transaction on the remote table storage.
+/// </summary>
+/// <remarks>
+/// Connection write operations using this transaction are queued until
+/// the <see cref="Commit"/> is called.
+/// </remarks>
+internal class TableTransaction : IDbTransaction
+{
+	/// <summary>
+	/// Creates new <see cref="TableTransaction"/> object.
+	/// </summary>
+	/// <param name="connection">The storage connection associated with the transaction.</param>
+	public TableTransaction(IDbConnection connection)
+	{
+		Connection = connection;
+	}
+	/// <summary>
+	/// The storage connection that created the transaction.
+	/// </summary>
+	/// <remarks>
+	/// Multiple connections can use the transaction, but only one is directly associated with the transaction.
+	/// </remarks>
+	public IDbConnection? Connection { get; }
+	/// <summary>
+	/// The isolation level of the transaction. It's always <see cref="IsolationLevel.Snapshot"/> on this transaction.
+	/// </summary>
+	public IsolationLevel IsolationLevel { get; } = IsolationLevel.Snapshot;
+	/// <summary>
+	/// Commits this transaction. This call actually performs a REST call to the remote service.
+	/// </summary>
+	/// <exception cref="NotImplementedException"></exception>
+	public void Commit()
+	{
+		throw new NotImplementedException();
+	}
+	/// <summary>
+	/// Disposes the <see cref="TableTransaction"/> object.
+	/// </summary>
+	public void Dispose()
+	{
+		/*
+		 * Nothing really to do here.
+		 */
+	}
+	/// <summary>
+	/// Rolls back any changes made in this transaction.
+	/// </summary>
+	public void Rollback()
+	{
+		/*
+		 * This call doesm't have to do enything since we weren't perform
+		 * any calls to the remote service. We just discard the operations.
+		 */
+	}
+}

src/Connected.ServiceModel.Client.Data/TableWriter.cs

@@ -0,0 +1,38 @@
+using Connected.Data.Storage;
+using Connected.Entities.Storage;
+
+namespace Connected.ServiceModel.Client.Data;
+
+internal sealed class TableWriter : TableCommand, IStorageWriter
+{
+	public TableWriter(IStorageOperation operation, IStorageConnection connection)
+		: base(operation, connection)
+	{
+	}
+
+	public async Task<int> Execute()
+	{
+		if (Connection is null)
+			return -1;
+
+		try
+		{
+			var recordsAffected = await Connection.Execute(this);
+
+			if (Connection.Behavior == StorageConnectionMode.Isolated)
+				await Connection.Commit();
+
+			return recordsAffected;
+		}
+		finally
+		{
+			if (Connection.Behavior == StorageConnectionMode.Isolated)
+			{
+				await Connection.Close();
+				await Connection.DisposeAsync();
+
+				Connection = null;
+			}
+		}
+	}
+}

src/Connected.ServiceModel.Client.Data/UpdateCommandBuilder.cs

@@ -0,0 +1,77 @@
+using System.Collections.Concurrent;
+using System.Reflection;
+using Connected.Entities.Annotations;
+using Connected.Entities.Storage;
+
+namespace Connected.ServiceModel.Client.Data;
+internal sealed class UpdateCommandBuilder : CommandBuilder
+{
+	private static readonly ConcurrentDictionary<string, StorageOperation> _cache;
+
+	static UpdateCommandBuilder()
+	{
+		_cache = new();
+	}
+
+	private static ConcurrentDictionary<string, StorageOperation> Cache => _cache;
+	private bool SupportsConcurrency { get; set; }
+	protected override bool TryGetExisting(out StorageOperation? result)
+	{
+		return Cache.TryGetValue(Entity.GetType().FullName, out result);
+	}
+
+	protected override StorageOperation OnBuild()
+	{
+		WriteLine($"UPDATE [{Schema.Schema}].[{Schema.Name}] SET");
+
+		WriteAssignments();
+		WriteWhere();
+
+		Trim();
+		Write(';');
+
+		var result = new StorageOperation { CommandText = CommandText, Concurrency = SupportsConcurrency ? DataConcurrencyMode.Enabled : DataConcurrencyMode.Disabled };
+
+		foreach (var parameter in Parameters)
+			result.AddParameter(parameter);
+
+		Cache.TryAdd(Entity.GetType().FullName, result);
+
+		return result;
+	}
+
+	private void WriteAssignments()
+	{
+		foreach (var property in Properties)
+		{
+			if (property.GetCustomAttribute<PrimaryKeyAttribute>() is not null)
+			{
+				WhereProperties.Add(property);
+
+				continue;
+			}
+
+			var parameter = CreateParameter(property);
+
+			WriteLine($"{ColumnName(property)} = {parameter.Name},");
+		}
+
+		Trim();
+	}
+
+	private void WriteWhere()
+	{
+		WriteLine(string.Empty);
+
+		for (var i = 0; i < WhereProperties.Count; i++)
+		{
+			var property = WhereProperties[i];
+			var parameter = CreateParameter(property);
+
+			if (i == 0)
+				WriteLine($" WHERE {ColumnName(property)} = {parameter.Name}");
+			else
+				WriteLine($" AND {ColumnName(property)} = {parameter.Name}");
+		}
+	}
+}

src/Connected.ServiceModel.Client.Data/version.json

@@ -0,0 +1,14 @@
+{
+  "$schema": "https://raw.githubusercontent.com/dotnet/Nerdbank.GitVersioning/main/src/NerdBank.GitVersioning/version.schema.json",
+  "version": "1.0-prerelease",
+  "semVer1NumericIdentifierPadding": 4,
+  "nugetPackageVersion": {
+    "semVer": 2, // optional. Set to either 1 or 2 to control how the NuGet package version string is generated. Default is 1.
+    "precision": "build" // optional. Use when you want to use a more or less precise package version than the default major.minor.build.
+  },
+  "cloudBuild": {
+    "buildNumber": {
+      "enabled": true
+    }
+  }
+}

src/Connected.ServiceModel.Client.Storage/Bootstrapper.cs

@@ -0,0 +1,15 @@
+using Connected.Annotations;
+using Connected.ServiceModel.Storage;
+using Microsoft.Extensions.DependencyInjection;
+
+[assembly: MicroService(MicroServiceType.Provider)]
+
+namespace Connected.ServiceModel.Client.Storage;
+
+internal class Bootstrapper : Startup
+{
+	protected override void OnConfigureServices(IServiceCollection services)
+	{
+		services.AddScoped(typeof(IStorageService), typeof(StorageService));
+	}
+}

src/Connected.ServiceModel.Client.Storage/Connected.ServiceModel.Client.Storage.csproj

@@ -0,0 +1,46 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+	<PropertyGroup>
+		<TargetFramework>net7.0</TargetFramework>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Nullable>enable</Nullable>
+		<GeneratePackageOnBuild>True</GeneratePackageOnBuild>
+		<Title>$(AssemblyName)</Title>
+		<Authors>Tom PIT ltd</Authors>
+		<Copyright>2022 Tom PIT ltd</Copyright>
+		<PackageProjectUrl>https://git.tompit.com/Connected/Info</PackageProjectUrl>
+		<PackageReadmeFile>README.md</PackageReadmeFile>
+		<PackageTags>connected;platform;</PackageTags>
+		<IncludeSymbols>True</IncludeSymbols>
+		<SymbolPackageFormat>snupkg</SymbolPackageFormat>
+		<PackageLicenseFile>LICENSE</PackageLicenseFile>
+		<PackageOutputPath>$(OutputPath)</PackageOutputPath>
+	</PropertyGroup>
+
+	<ItemGroup>
+		<PackageReference Include="Connected.ServiceModel" Version="1.0.*-*" />
+		<PackageReference Include="Connected.Entities" Version="1.0.*-*" />
+		<PackageReference Include="Connected.Services" Version="1.0.*-*" />
+		<PackageReference Include="Connected.ServiceModel.Client" Version="1.0.*-*" />
+		<PackageReference Include="Nerdbank.GitVersioning"
+									Version="3.5.119"
+									PrivateAssets="all"
+									Condition="!Exists('packages.config')" />
+	</ItemGroup>
+
+	<ItemGroup>
+		<None Include="..\..\LICENSE">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+		<None Include="..\..\README.md">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+	</ItemGroup>
+
+	<Target Name="CopyPackages" AfterTargets="Pack">
+		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
+		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
+	</Target>
+</Project>

src/Connected.ServiceModel.Client.Storage/StorageOps.cs

@@ -0,0 +1,28 @@
+using Connected.Net;
+using Connected.ServiceModel.Client.Net;
+using Connected.ServiceModel.Client.Subscription;
+using Connected.ServiceModel.Storage;
+using Connected.Services;
+
+namespace Connected.ServiceModel.Client.Storage;
+
+internal sealed class DeleteDirectory : ServiceAction<DeleteDirectoryArgs>
+{
+	public DeleteDirectory(ISubscriptionService subscription, IHttpService http, IConnectedServer server, ICancellationContext cancel)
+	{
+		Subscription = subscription;
+		Http = http;
+		Server = server;
+		Cancel = cancel;
+	}
+
+	public ISubscriptionService Subscription { get; }
+	public IHttpService Http { get; }
+	public IConnectedServer Server { get; }
+	public ICancellationContext Cancel { get; }
+
+	protected override async Task OnInvoke()
+	{
+		await Http.Post(await Server.SelectUrl(new ConnectedServerUrlArgs { Kind = ConnectedUrlKind.FileSystem }), Arguments, Cancel.CancellationToken);
+	}
+}

src/Connected.ServiceModel.Client.Storage/StorageService.cs

@@ -0,0 +1,57 @@
+using System.Collections.Immutable;
+using Connected.ServiceModel.Storage;
+using Connected.Services;
+
+namespace Connected.ServiceModel.Client.Storage;
+
+internal class StorageService : Service, IStorageService
+{
+	public StorageService(IContext context) : base(context)
+	{
+	}
+
+	public async Task DeleteDirectory(DeleteDirectoryArgs args)
+	{
+		await Invoke(GetOperation<DeleteDirectory>(), args);
+	}
+
+	public Task DeleteFile(DeleteFileArgs args)
+	{
+		throw new NotImplementedException();
+	}
+
+	public Task InsertDirectory(InsertDirectoryArgs args)
+	{
+		throw new NotImplementedException();
+	}
+
+	public Task MoveFile(MoveFileArgs args)
+	{
+		throw new NotImplementedException();
+	}
+
+	public Task<ImmutableList<IDirectory>?> QueryDirectories(DirectoryArgs args)
+	{
+		throw new NotImplementedException();
+	}
+
+	public Task<ImmutableList<IFile>?> QueryFiles(DirectoryArgs args)
+	{
+		throw new NotImplementedException();
+	}
+
+	public Task<byte[]?> SelectFile(FileArgs args)
+	{
+		throw new NotImplementedException();
+	}
+
+	public Task UpdateDirectory(UpdateDirectoryArgs args)
+	{
+		throw new NotImplementedException();
+	}
+
+	public Task UpdateFile(UpdateFileArgs args)
+	{
+		throw new NotImplementedException();
+	}
+}

src/Connected.ServiceModel.Client.Storage/version.json

@@ -0,0 +1,14 @@
+{
+  "$schema": "https://raw.githubusercontent.com/dotnet/Nerdbank.GitVersioning/main/src/NerdBank.GitVersioning/version.schema.json",
+  "version": "1.0-prerelease",
+  "semVer1NumericIdentifierPadding": 4,
+  "nugetPackageVersion": {
+    "semVer": 2, // optional. Set to either 1 or 2 to control how the NuGet package version string is generated. Default is 1.
+    "precision": "build" // optional. Use when you want to use a more or less precise package version than the default major.minor.build.
+  },
+  "cloudBuild": {
+    "buildNumber": {
+      "enabled": true
+    }
+  }
+}

src/Connected.ServiceModel.Client/Bootstrapper.cs

@@ -0,0 +1,16 @@
+using Connected.Annotations;
+using Connected.ServiceModel.Client.Subscription;
+using Microsoft.Extensions.DependencyInjection;
+
+[assembly: MicroService(MicroServiceType.Provider)]
+
+namespace Connected.ServiceModel.Client.Net;
+
+internal class Bootstrapper : Startup
+{
+	protected override void OnConfigureServices(IServiceCollection services)
+	{
+		services.AddScoped(typeof(IConnectedServer), typeof(ConnectedServer));
+		services.AddScoped(typeof(ISubscriptionService), typeof(SubscriptionService));
+	}
+}

src/Connected.ServiceModel.Client/Connected.ServiceModel.Client.csproj

@@ -0,0 +1,44 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+	<PropertyGroup>
+		<TargetFramework>net7.0</TargetFramework>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Nullable>enable</Nullable>
+		<GeneratePackageOnBuild>True</GeneratePackageOnBuild>
+		<Title>$(AssemblyName)</Title>
+		<Authors>Tom PIT ltd</Authors>
+		<Copyright>2022 Tom PIT ltd</Copyright>
+		<PackageProjectUrl>https://git.tompit.com/Connected/Info</PackageProjectUrl>
+		<PackageReadmeFile>README.md</PackageReadmeFile>
+		<PackageTags>connected;platform;</PackageTags>
+		<IncludeSymbols>True</IncludeSymbols>
+		<SymbolPackageFormat>snupkg</SymbolPackageFormat>
+		<PackageLicenseFile>LICENSE</PackageLicenseFile>
+		<PackageOutputPath>$(OutputPath)</PackageOutputPath>
+	</PropertyGroup>
+
+	<ItemGroup>
+		<PackageReference Include="Connected.Entities" Version="1.0.*-*"/>
+		<PackageReference Include="Connected.Services" Version="1.0.*-*"/>
+		<PackageReference Include="Nerdbank.GitVersioning"
+									Version="3.5.119"
+									PrivateAssets="all"
+									Condition="!Exists('packages.config')" />
+	</ItemGroup>
+
+	<ItemGroup>
+		<None Include="..\..\LICENSE">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+		<None Include="..\..\README.md">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+	</ItemGroup>
+
+	<Target Name="CopyPackages" AfterTargets="Pack">
+		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
+		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
+	</Target>
+</Project>

src/Connected.ServiceModel.Client/Net/ConnectedServer.cs

@@ -0,0 +1,15 @@
+using Connected.Services;
+
+namespace Connected.ServiceModel.Client.Net;
+
+internal class ConnectedServer : Service, IConnectedServer
+{
+	public ConnectedServer(IContext context) : base(context)
+	{
+	}
+
+	public async Task<string?> SelectUrl(ConnectedServerUrlArgs args)
+	{
+		return await Invoke(GetOperation<SelectUrl>(), args);
+	}
+}

src/Connected.ServiceModel.Client/Net/ConnectedServerArgs.cs

@@ -0,0 +1,13 @@
+namespace Connected.ServiceModel.Client.Net;
+
+public enum ConnectedUrlKind
+{
+	Root = 0,
+	FileSystem = 1,
+	TableStorage = 2
+}
+
+public sealed class ConnectedServerUrlArgs : Dto
+{
+	public ConnectedUrlKind Kind { get; set; } = ConnectedUrlKind.Root;
+}

src/Connected.ServiceModel.Client/Net/ConnectedServerOps.cs

@@ -0,0 +1,30 @@
+using Connected.Services;
+using Microsoft.Extensions.Configuration;
+
+namespace Connected.ServiceModel.Client.Net;
+
+internal sealed class SelectUrl : ServiceFunction<ConnectedServerUrlArgs, string>
+{
+	private const string Root = "https://connected.tompit.com";
+	private readonly string? _rootOverride = null;
+
+	public SelectUrl(IConfiguration configuration)
+	{
+		_rootOverride = configuration?.GetValue<string?>("connectedServicesRootUrl", null);
+	}
+
+	private string RootUrl => string.IsNullOrWhiteSpace(_rootOverride) ? Root : _rootOverride;
+
+	protected override async Task<string> OnInvoke()
+	{
+		await Task.CompletedTask;
+
+		return Arguments.Kind switch
+		{
+			ConnectedUrlKind.Root => RootUrl,
+			ConnectedUrlKind.FileSystem => $"{RootUrl}/services/fileSystem",
+			ConnectedUrlKind.TableStorage => $"{RootUrl}/services/tables",
+			_ => throw new NotImplementedException(),
+		};
+	}
+}

src/Connected.ServiceModel.Client/Net/IConnectedServer.cs

@@ -0,0 +1,6 @@
+namespace Connected.ServiceModel.Client.Net;
+
+public interface IConnectedServer
+{
+	Task<string?> SelectUrl(ConnectedServerUrlArgs args);
+}

src/Connected.ServiceModel.Client/Subscription/ISubscription.cs

@@ -0,0 +1,7 @@
+using Connected.Data;
+
+namespace Connected.ServiceModel.Client.Subscription;
+
+public interface ISubscription : IPrimaryKey<int>
+{
+}

src/Connected.ServiceModel.Client/Subscription/ISubscriptionService.cs

@@ -0,0 +1,6 @@
+namespace Connected.ServiceModel.Client.Subscription;
+
+public interface ISubscriptionService
+{
+	Task<ISubscription?> Select();
+}

src/Connected.ServiceModel.Client/Subscription/Subscription.cs

@@ -0,0 +1,9 @@
+using Connected.Entities;
+using Connected.Entities.Annotations;
+
+namespace Connected.ServiceModel.Client.Subscription;
+
+[Persistence(Persistence = ColumnPersistence.InMemory)]
+internal record Subscription : Entity<int>, ISubscription
+{
+}

src/Connected.ServiceModel.Client/Subscription/SubscriptionOps.cs

@@ -0,0 +1,16 @@
+using Connected.Services;
+
+namespace Connected.ServiceModel.Client.Subscription;
+
+internal sealed class SelectSubscription : ServiceFunction<IDto, ISubscription?>
+{
+	protected override async Task<ISubscription?> OnInvoke()
+	{
+		await Task.CompletedTask;
+
+		return new Subscription
+		{
+			Id = 1
+		};
+	}
+}

src/Connected.ServiceModel.Client/Subscription/SubscriptionService.cs

@@ -0,0 +1,15 @@
+using Connected.Services;
+
+namespace Connected.ServiceModel.Client.Subscription;
+
+internal class SubscriptionService : Service, ISubscriptionService
+{
+	public SubscriptionService(IContext context) : base(context)
+	{
+	}
+
+	public async Task<ISubscription?> Select()
+	{
+		return await Invoke(GetOperation<SelectSubscription>(), Dto.Empty);
+	}
+}

src/Connected.ServiceModel.Client/version.json

@@ -0,0 +1,14 @@
+{
+  "$schema": "https://raw.githubusercontent.com/dotnet/Nerdbank.GitVersioning/main/src/NerdBank.GitVersioning/version.schema.json",
+  "version": "1.0-prerelease",
+  "semVer1NumericIdentifierPadding": 4,
+  "nugetPackageVersion": {
+    "semVer": 2, // optional. Set to either 1 or 2 to control how the NuGet package version string is generated. Default is 1.
+    "precision": "build" // optional. Use when you want to use a more or less precise package version than the default major.minor.build.
+  },
+  "cloudBuild": {
+    "buildNumber": {
+      "enabled": true
+    }
+  }
+}