s4-dsdb: add auto-normalisation of attributes
[samba.git] / source4 / dsdb / schema / schema_syntax.c
index 99f85c26a8221a59da1d8c8563921365d9630ece..501ab3adedbb28446900daecf4848f37e9a2de58 100644 (file)
@@ -1,7 +1,7 @@
-/* 
+/*
    Unix SMB/CIFS mplementation.
    DSDB schema syntaxes
-   
+
    Copyright (C) Stefan Metzmacher <metze@samba.org> 2006
    Copyright (C) Simo Sorce 2005
    Copyright (C) Andrew Bartlett <abartlet@samba.org> 2008
    it under the terms of the GNU 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 General Public License for more details.
-   
+
    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
-   
+
 */
 #include "includes.h"
 #include "dsdb/samdb/samdb.h"
 #include "librpc/gen_ndr/ndr_drsuapi.h"
 #include "librpc/gen_ndr/ndr_security.h"
 #include "librpc/gen_ndr/ndr_misc.h"
-#include "lib/ldb/include/ldb.h"
-#include "lib/ldb/include/ldb_errors.h"
+#include <ldb.h>
+#include <ldb_errors.h>
 #include "system/time.h"
 #include "../lib/util/charset/charset.h"
 #include "librpc/ndr/libndr.h"
+#include "../lib/util/asn1.h"
+
+/**
+ * Initialize dsdb_syntax_ctx with default values
+ * for common cases.
+ */
+void dsdb_syntax_ctx_init(struct dsdb_syntax_ctx *ctx,
+                         struct ldb_context *ldb,
+                         const struct dsdb_schema *schema)
+{
+       ctx->ldb        = ldb;
+       ctx->schema     = schema;
+
+       /*
+        * 'true' will keep current behavior,
+        * i.e. attributeID_id will be returned by default
+        */
+       ctx->is_schema_nc = true;
+
+       ctx->pfm_remote = NULL;
+}
+
+
+/**
+ * Returns ATTID for DRS attribute.
+ *
+ * ATTID depends on whether we are replicating
+ * Schema NC or msDs-IntId is set for schemaAttribute
+ * for the attribute.
+ */
+uint32_t dsdb_attribute_get_attid(const struct dsdb_attribute *attr,
+                                 bool for_schema_nc)
+{
+       if (!for_schema_nc && attr->msDS_IntId) {
+               return attr->msDS_IntId;
+       }
+
+       return attr->attributeID_id;
+}
+
+/**
+ * Map an ATTID from remote DC to a local ATTID
+ * using remote prefixMap
+ */
+static bool dsdb_syntax_attid_from_remote_attid(const struct dsdb_syntax_ctx *ctx,
+                                               TALLOC_CTX *mem_ctx,
+                                               uint32_t id_remote,
+                                               uint32_t *id_local)
+{
+       WERROR werr;
+       const char *oid;
+
+       /*
+        * map remote ATTID to local directly in case
+        * of no remote prefixMap (during provision for instance)
+        */
+       if (!ctx->pfm_remote) {
+               *id_local = id_remote;
+               return true;
+       }
 
-static WERROR dsdb_syntax_FOOBAR_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                               const struct dsdb_schema *schema,
+       werr = dsdb_schema_pfm_oid_from_attid(ctx->pfm_remote, id_remote, mem_ctx, &oid);
+       if (!W_ERROR_IS_OK(werr)) {
+               DEBUG(0,("ATTID->OID failed (%s) for: 0x%08X\n", win_errstr(werr), id_remote));
+               return false;
+       }
+
+       werr = dsdb_schema_pfm_make_attid(ctx->schema->prefixmap, oid, id_local);
+       if (!W_ERROR_IS_OK(werr)) {
+               DEBUG(0,("OID->ATTID failed (%s) for: %s\n", win_errstr(werr), oid));
+               return false;
+       }
+
+       return true;
+}
+
+static WERROR dsdb_syntax_FOOBAR_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                const struct dsdb_attribute *attr,
                                                const struct drsuapi_DsReplicaAttribute *in,
                                                TALLOC_CTX *mem_ctx,
                                                struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -65,8 +139,7 @@ static WERROR dsdb_syntax_FOOBAR_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_FOOBAR_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                               const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_FOOBAR_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                const struct dsdb_attribute *attr,
                                                const struct ldb_message_element *in,
                                                TALLOC_CTX *mem_ctx,
@@ -75,34 +148,20 @@ static WERROR dsdb_syntax_FOOBAR_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_FOOBAR;
 }
 
-static WERROR dsdb_syntax_FOOBAR_validate_ldb(struct ldb_context *ldb,
-                                             const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_FOOBAR_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                              const struct dsdb_attribute *attr,
                                              const struct ldb_message_element *in)
 {
        return WERR_FOOBAR;
 }
 
-static WERROR dsdb_syntax_ALLOW_validate_ldb(struct ldb_context *ldb,
-                                            const struct dsdb_schema *schema,
-                                            const struct dsdb_attribute *attr,
-                                            const struct ldb_message_element *in)
-{
-       if (attr->attributeID_id == 0xFFFFFFFF) {
-               return WERR_FOOBAR;
-       }
-
-       return WERR_OK;
-}
-
-static WERROR dsdb_syntax_BOOL_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                             const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_BOOL_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                              const struct dsdb_attribute *attr,
                                              const struct drsuapi_DsReplicaAttribute *in,
                                              TALLOC_CTX *mem_ctx,
                                              struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -140,21 +199,21 @@ static WERROR dsdb_syntax_BOOL_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_BOOL_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                             const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_BOOL_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                              const struct dsdb_attribute *attr,
                                              const struct ldb_message_element *in,
                                              TALLOC_CTX *mem_ctx,
                                              struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -182,20 +241,23 @@ static WERROR dsdb_syntax_BOOL_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_BOOL_validate_ldb(struct ldb_context *ldb,
-                                           const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_BOOL_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                            const struct dsdb_attribute *attr,
                                            const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
        for (i=0; i < in->num_values; i++) {
                int t, f;
 
+               if (in->values[i].length == 0) {
+                       return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
+               }
+
                t = strncmp("TRUE",
                            (const char *)in->values[i].data,
                            in->values[i].length);
@@ -211,14 +273,13 @@ static WERROR dsdb_syntax_BOOL_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_INT32_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                              const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_INT32_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                               const struct dsdb_attribute *attr,
                                               const struct drsuapi_DsReplicaAttribute *in,
                                               TALLOC_CTX *mem_ctx,
                                               struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -251,21 +312,21 @@ static WERROR dsdb_syntax_INT32_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_INT32_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                              const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_INT32_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                               const struct dsdb_attribute *attr,
                                               const struct ldb_message_element *in,
                                               TALLOC_CTX *mem_ctx,
                                               struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -293,14 +354,13 @@ static WERROR dsdb_syntax_INT32_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_INT32_validate_ldb(struct ldb_context *ldb,
-                                            const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_INT32_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                             const struct dsdb_attribute *attr,
                                             const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
@@ -340,14 +400,13 @@ static WERROR dsdb_syntax_INT32_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_INT64_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                              const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_INT64_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                               const struct dsdb_attribute *attr,
                                               const struct drsuapi_DsReplicaAttribute *in,
                                               TALLOC_CTX *mem_ctx,
                                               struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -380,21 +439,21 @@ static WERROR dsdb_syntax_INT64_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_INT64_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                              const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_INT64_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                               const struct dsdb_attribute *attr,
                                               const struct ldb_message_element *in,
                                               TALLOC_CTX *mem_ctx,
                                               struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -420,14 +479,13 @@ static WERROR dsdb_syntax_INT64_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_INT64_validate_ldb(struct ldb_context *ldb,
-                                            const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_INT64_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                             const struct dsdb_attribute *attr,
                                             const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
@@ -466,14 +524,13 @@ static WERROR dsdb_syntax_INT64_validate_ldb(struct ldb_context *ldb,
 
        return WERR_OK;
 }
-static WERROR dsdb_syntax_NTTIME_UTC_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                                   const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_NTTIME_UTC_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                    const struct dsdb_attribute *attr,
                                                    const struct drsuapi_DsReplicaAttribute *in,
                                                    TALLOC_CTX *mem_ctx,
                                                    struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -497,10 +554,15 @@ static WERROR dsdb_syntax_NTTIME_UTC_drsuapi_to_ldb(struct ldb_context *ldb,
                }
 
                v = BVAL(in->value_ctr.values[i].blob->data, 0);
+               if (v == 0) {
+                       /* special case for 1601 zero timestamp */
+                       out->values[i] = data_blob_string_const("16010101000000.0Z");
+                       continue;
+               }
                v *= 10000000;
                t = nt_time_to_unix(v);
 
-               /* 
+               /*
                 * NOTE: On a w2k3 server you can set a GeneralizedTime string
                 *       via LDAP, but you get back an UTCTime string,
                 *       but via DRSUAPI you get back the NTTIME_1sec value
@@ -509,7 +571,7 @@ static WERROR dsdb_syntax_NTTIME_UTC_drsuapi_to_ldb(struct ldb_context *ldb,
                 *       So if we store the UTCTime string in our ldb
                 *       we'll loose information!
                 */
-               str = ldb_timestring_utc(out->values, t); 
+               str = ldb_timestring_utc(out->values, t);
                W_ERROR_HAVE_NO_MEMORY(str);
                out->values[i] = data_blob_string_const(str);
        }
@@ -517,21 +579,21 @@ static WERROR dsdb_syntax_NTTIME_UTC_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_NTTIME_UTC_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                                   const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_NTTIME_UTC_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                    const struct dsdb_attribute *attr,
                                                    const struct ldb_message_element *in,
                                                    TALLOC_CTX *mem_ctx,
                                                    struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -550,6 +612,11 @@ static WERROR dsdb_syntax_NTTIME_UTC_ldb_to_drsuapi(struct ldb_context *ldb,
                blobs[i] = data_blob_talloc(blobs, NULL, 8);
                W_ERROR_HAVE_NO_MEMORY(blobs[i].data);
 
+               if (ldb_val_string_cmp("16010101000000.0Z", &in->values[i]) == 0) {
+                       SBVALS(blobs[i].data, 0, 0);
+                       continue;
+               }
+
                t = ldb_string_utc_to_time((const char *)in->values[i].data);
                unix_to_nt_time(&v, t);
                v /= 10000000;
@@ -560,14 +627,13 @@ static WERROR dsdb_syntax_NTTIME_UTC_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_NTTIME_UTC_validate_ldb(struct ldb_context *ldb,
-                                                 const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_NTTIME_UTC_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                                  const struct dsdb_attribute *attr,
                                                  const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
@@ -581,9 +647,8 @@ static WERROR dsdb_syntax_NTTIME_UTC_validate_ldb(struct ldb_context *ldb,
                }
                memcpy(buf, in->values[i].data, in->values[i].length);
 
-               errno = 0;
                t = ldb_string_utc_to_time(buf);
-               if (errno != 0) {
+               if (t == 0) {
                        return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
                }
 
@@ -608,14 +673,13 @@ static WERROR dsdb_syntax_NTTIME_UTC_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_NTTIME_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                               const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_NTTIME_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                const struct dsdb_attribute *attr,
                                                const struct drsuapi_DsReplicaAttribute *in,
                                                TALLOC_CTX *mem_ctx,
                                                struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -639,10 +703,15 @@ static WERROR dsdb_syntax_NTTIME_drsuapi_to_ldb(struct ldb_context *ldb,
                }
 
                v = BVAL(in->value_ctr.values[i].blob->data, 0);
+               if (v == 0) {
+                       /* special case for 1601 zero timestamp */
+                       out->values[i] = data_blob_string_const("16010101000000.0Z");
+                       continue;
+               }
                v *= 10000000;
                t = nt_time_to_unix(v);
 
-               str = ldb_timestring(out->values, t); 
+               str = ldb_timestring(out->values, t);
                W_ERROR_HAVE_NO_MEMORY(str);
 
                out->values[i] = data_blob_string_const(str);
@@ -651,21 +720,21 @@ static WERROR dsdb_syntax_NTTIME_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_NTTIME_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                               const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_NTTIME_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                const struct dsdb_attribute *attr,
                                                const struct ldb_message_element *in,
                                                TALLOC_CTX *mem_ctx,
                                                struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -685,6 +754,11 @@ static WERROR dsdb_syntax_NTTIME_ldb_to_drsuapi(struct ldb_context *ldb,
                blobs[i] = data_blob_talloc(blobs, NULL, 8);
                W_ERROR_HAVE_NO_MEMORY(blobs[i].data);
 
+               if (ldb_val_string_cmp("16010101000000.0Z", &in->values[i]) == 0) {
+                       SBVALS(blobs[i].data, 0, 0);
+                       continue;
+               }
+
                ret = ldb_val_to_time(&in->values[i], &t);
                if (ret != LDB_SUCCESS) {
                        return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
@@ -698,14 +772,13 @@ static WERROR dsdb_syntax_NTTIME_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_NTTIME_validate_ldb(struct ldb_context *ldb,
-                                             const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_NTTIME_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                              const struct dsdb_attribute *attr,
                                              const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
@@ -734,14 +807,13 @@ static WERROR dsdb_syntax_NTTIME_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DATA_BLOB_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                                  const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DATA_BLOB_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct drsuapi_DsReplicaAttribute *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -768,21 +840,21 @@ static WERROR dsdb_syntax_DATA_BLOB_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DATA_BLOB_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                                  const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DATA_BLOB_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct ldb_message_element *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -802,12 +874,11 @@ static WERROR dsdb_syntax_DATA_BLOB_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DATA_BLOB_validate_one_val(struct ldb_context *ldb,
-                                                    const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DATA_BLOB_validate_one_val(const struct dsdb_syntax_ctx *ctx,
                                                     const struct dsdb_attribute *attr,
                                                     const struct ldb_val *val)
 {
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
@@ -826,15 +897,14 @@ static WERROR dsdb_syntax_DATA_BLOB_validate_one_val(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DATA_BLOB_validate_ldb(struct ldb_context *ldb,
-                                                const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DATA_BLOB_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                                 const struct dsdb_attribute *attr,
                                                 const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
        WERROR status;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
@@ -843,8 +913,7 @@ static WERROR dsdb_syntax_DATA_BLOB_validate_ldb(struct ldb_context *ldb,
                        return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
                }
 
-               status = dsdb_syntax_DATA_BLOB_validate_one_val(ldb,
-                                                               schema,
+               status = dsdb_syntax_DATA_BLOB_validate_one_val(ctx,
                                                                attr,
                                                                &in->values[i]);
                if (!W_ERROR_IS_OK(status)) {
@@ -855,14 +924,13 @@ static WERROR dsdb_syntax_DATA_BLOB_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR _dsdb_syntax_auto_OID_drsuapi_to_ldb(struct ldb_context *ldb,
-                                                  const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_auto_OID_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct drsuapi_DsReplicaAttribute *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -888,13 +956,15 @@ static WERROR _dsdb_syntax_auto_OID_drsuapi_to_ldb(struct ldb_context *ldb,
 
                v = IVAL(in->value_ctr.values[i].blob->data, 0);
 
-               if ((c = dsdb_class_by_governsID_id(schema, v))) {
+               if ((c = dsdb_class_by_governsID_id(ctx->schema, v))) {
                        str = talloc_strdup(out->values, c->lDAPDisplayName);
-               } else if ((a = dsdb_attribute_by_attributeID_id(schema, v))) {
+               } else if ((a = dsdb_attribute_by_attributeID_id(ctx->schema, v))) {
                        str = talloc_strdup(out->values, a->lDAPDisplayName);
                } else {
                        WERROR werr;
-                       werr = dsdb_schema_pfm_oid_from_attid(schema->prefixmap, v, out->values, &str);
+                       SMB_ASSERT(ctx->pfm_remote);
+                       werr = dsdb_schema_pfm_oid_from_attid(ctx->pfm_remote, v,
+                                                             out->values, &str);
                        W_ERROR_NOT_OK_RETURN(werr);
                }
                W_ERROR_HAVE_NO_MEMORY(str);
@@ -906,14 +976,13 @@ static WERROR _dsdb_syntax_auto_OID_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR _dsdb_syntax_OID_obj_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                                 const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_OID_obj_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                  const struct dsdb_attribute *attr,
                                                  const struct drsuapi_DsReplicaAttribute *in,
                                                  TALLOC_CTX *mem_ctx,
                                                  struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -938,8 +1007,15 @@ static WERROR _dsdb_syntax_OID_obj_drsuapi_to_ldb(struct ldb_context *ldb,
 
                v = IVAL(in->value_ctr.values[i].blob->data, 0);
 
-               c = dsdb_class_by_governsID_id(schema, v);
+               /* convert remote ATTID to local ATTID */
+               if (!dsdb_syntax_attid_from_remote_attid(ctx, mem_ctx, v, &v)) {
+                       DEBUG(1,(__location__ ": Failed to map remote ATTID to local ATTID!\n"));
+                       return WERR_FOOBAR;
+               }
+
+               c = dsdb_class_by_governsID_id(ctx->schema, v);
                if (!c) {
+                       DEBUG(1,(__location__ ": Unknown governsID 0x%08X\n", v));
                        return WERR_FOOBAR;
                }
 
@@ -953,14 +1029,13 @@ static WERROR _dsdb_syntax_OID_obj_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR _dsdb_syntax_OID_attr_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                                  const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_OID_attr_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct drsuapi_DsReplicaAttribute *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -985,8 +1060,15 @@ static WERROR _dsdb_syntax_OID_attr_drsuapi_to_ldb(struct ldb_context *ldb,
 
                v = IVAL(in->value_ctr.values[i].blob->data, 0);
 
-               a = dsdb_attribute_by_attributeID_id(schema, v);
+               /* convert remote ATTID to local ATTID */
+               if (!dsdb_syntax_attid_from_remote_attid(ctx, mem_ctx, v, &v)) {
+                       DEBUG(1,(__location__ ": Failed to map remote ATTID to local ATTID!\n"));
+                       return WERR_FOOBAR;
+               }
+
+               a = dsdb_attribute_by_attributeID_id(ctx->schema, v);
                if (!a) {
+                       DEBUG(1,(__location__ ": Unknown attributeID_id 0x%08X\n", v));
                        return WERR_FOOBAR;
                }
 
@@ -1000,14 +1082,21 @@ static WERROR _dsdb_syntax_OID_attr_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR _dsdb_syntax_OID_oid_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                                 const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_OID_oid_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                  const struct dsdb_attribute *attr,
                                                  const struct drsuapi_DsReplicaAttribute *in,
                                                  TALLOC_CTX *mem_ctx,
                                                  struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
+       const struct dsdb_schema_prefixmap *prefixmap;
+
+       if (ctx->pfm_remote != NULL) {
+               prefixmap = ctx->pfm_remote;
+       } else {
+               prefixmap = ctx->schema->prefixmap;
+       }
+       SMB_ASSERT(prefixmap);
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -1032,8 +1121,13 @@ static WERROR _dsdb_syntax_OID_oid_drsuapi_to_ldb(struct ldb_context *ldb,
 
                attid = IVAL(in->value_ctr.values[i].blob->data, 0);
 
-               status = dsdb_schema_pfm_oid_from_attid(schema->prefixmap, attid, out->values, &oid);
-               W_ERROR_NOT_OK_RETURN(status);
+               status = dsdb_schema_pfm_oid_from_attid(prefixmap, attid,
+                                                       out->values, &oid);
+               if (!W_ERROR_IS_OK(status)) {
+                       DEBUG(0,(__location__ ": Error: Unknown ATTID 0x%08X\n",
+                                attid));
+                       return status;
+               }
 
                out->values[i] = data_blob_string_const(oid);
        }
@@ -1041,17 +1135,17 @@ static WERROR _dsdb_syntax_OID_oid_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR _dsdb_syntax_auto_OID_ldb_to_drsuapi(struct ldb_context *ldb,
-                                                  const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_auto_OID_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct ldb_message_element *in,
                                                   TALLOC_CTX *mem_ctx,
-                                                 struct drsuapi_DsReplicaAttribute *out)
+                                                  struct drsuapi_DsReplicaAttribute *out)
 {
-        uint32_t i;
+        unsigned int i;
         DATA_BLOB *blobs;
 
-        out->attid= attr->attributeID_id;
+        out->attid= dsdb_attribute_get_attid(attr,
+                                            ctx->is_schema_nc);
         out->value_ctr.num_values= in->num_values;
         out->value_ctr.values= talloc_array(mem_ctx,
                                             struct drsuapi_DsAttributeValue,
@@ -1075,16 +1169,16 @@ static WERROR _dsdb_syntax_auto_OID_ldb_to_drsuapi(struct ldb_context *ldb,
                   order to the order used in ldap */
                v = &in->values[(in->num_values-1)-i];
 
-               if ((obj_class = dsdb_class_by_lDAPDisplayName_ldb_val(schema, v))) {
+               if ((obj_class = dsdb_class_by_lDAPDisplayName_ldb_val(ctx->schema, v))) {
                        SIVAL(blobs[i].data, 0, obj_class->governsID_id);
-               } else if ((obj_attr = dsdb_attribute_by_lDAPDisplayName_ldb_val(schema, v))) {
+               } else if ((obj_attr = dsdb_attribute_by_lDAPDisplayName_ldb_val(ctx->schema, v))) {
                        SIVAL(blobs[i].data, 0, obj_attr->attributeID_id);
                } else {
                        uint32_t attid;
                        WERROR werr;
-                       werr = dsdb_schema_pfm_make_attid(schema->prefixmap,
-                                                         (const char *)v->data,
-                                                         &attid);
+                       werr = dsdb_schema_pfm_attid_from_oid(ctx->schema->prefixmap,
+                                                             (const char *)v->data,
+                                                             &attid);
                        W_ERROR_NOT_OK_RETURN(werr);
                        SIVAL(blobs[i].data, 0, attid);
                }
@@ -1095,17 +1189,17 @@ static WERROR _dsdb_syntax_auto_OID_ldb_to_drsuapi(struct ldb_context *ldb,
         return WERR_OK;
 }
 
-static WERROR _dsdb_syntax_OID_obj_ldb_to_drsuapi(struct ldb_context *ldb,
-                                                 const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_OID_obj_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                  const struct dsdb_attribute *attr,
                                                  const struct ldb_message_element *in,
                                                  TALLOC_CTX *mem_ctx,
                                                  struct drsuapi_DsReplicaAttribute *out)
 {
-        uint32_t i;
+        unsigned int i;
         DATA_BLOB *blobs;
 
-        out->attid= attr->attributeID_id;
+        out->attid= dsdb_attribute_get_attid(attr,
+                                            ctx->is_schema_nc);
         out->value_ctr.num_values= in->num_values;
         out->value_ctr.values= talloc_array(mem_ctx,
                                             struct drsuapi_DsAttributeValue,
@@ -1125,7 +1219,7 @@ static WERROR _dsdb_syntax_OID_obj_ldb_to_drsuapi(struct ldb_context *ldb,
 
                /* in DRS windows puts the classes in the opposite
                   order to the order used in ldap */
-               obj_class = dsdb_class_by_lDAPDisplayName(schema,
+               obj_class = dsdb_class_by_lDAPDisplayName(ctx->schema,
                                                          (const char *)in->values[(in->num_values-1)-i].data);
                if (!obj_class) {
                        return WERR_FOOBAR;
@@ -1137,17 +1231,17 @@ static WERROR _dsdb_syntax_OID_obj_ldb_to_drsuapi(struct ldb_context *ldb,
         return WERR_OK;
 }
 
-static WERROR _dsdb_syntax_OID_attr_ldb_to_drsuapi(struct ldb_context *ldb,
-                                                  const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_OID_attr_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct ldb_message_element *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct drsuapi_DsReplicaAttribute *out)
 {
-        uint32_t i;
+        unsigned int i;
         DATA_BLOB *blobs;
 
-        out->attid= attr->attributeID_id;
+        out->attid= dsdb_attribute_get_attid(attr,
+                                            ctx->is_schema_nc);
         out->value_ctr.num_values= in->num_values;
         out->value_ctr.values= talloc_array(mem_ctx,
                                             struct drsuapi_DsAttributeValue,
@@ -1165,7 +1259,7 @@ static WERROR _dsdb_syntax_OID_attr_ldb_to_drsuapi(struct ldb_context *ldb,
                blobs[i] = data_blob_talloc(blobs, NULL, 4);
                W_ERROR_HAVE_NO_MEMORY(blobs[i].data);
 
-               obj_attr = dsdb_attribute_by_lDAPDisplayName(schema, (const char *)in->values[i].data);
+               obj_attr = dsdb_attribute_by_lDAPDisplayName(ctx->schema, (const char *)in->values[i].data);
                if (!obj_attr) {
                        return WERR_FOOBAR;
                }
@@ -1176,17 +1270,17 @@ static WERROR _dsdb_syntax_OID_attr_ldb_to_drsuapi(struct ldb_context *ldb,
         return WERR_OK;
 }
 
-static WERROR _dsdb_syntax_OID_oid_ldb_to_drsuapi(struct ldb_context *ldb,
-                                                 const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_OID_oid_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                  const struct dsdb_attribute *attr,
                                                  const struct ldb_message_element *in,
                                                  TALLOC_CTX *mem_ctx,
                                                  struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       out->attid= attr->attributeID_id;
+       out->attid= dsdb_attribute_get_attid(attr,
+                                            ctx->is_schema_nc);
        out->value_ctr.num_values= in->num_values;
        out->value_ctr.values= talloc_array(mem_ctx,
                                            struct drsuapi_DsAttributeValue,
@@ -1205,9 +1299,9 @@ static WERROR _dsdb_syntax_OID_oid_ldb_to_drsuapi(struct ldb_context *ldb,
                blobs[i] = data_blob_talloc(blobs, NULL, 4);
                W_ERROR_HAVE_NO_MEMORY(blobs[i].data);
 
-               status = dsdb_schema_pfm_make_attid(schema->prefixmap,
-                                                   (const char *)in->values[i].data,
-                                                   &attid);
+               status = dsdb_schema_pfm_attid_from_oid(ctx->schema->prefixmap,
+                                                       (const char *)in->values[i].data,
+                                                       &attid);
                W_ERROR_NOT_OK_RETURN(status);
 
                SIVAL(blobs[i].data, 0, attid);
@@ -1216,85 +1310,190 @@ static WERROR _dsdb_syntax_OID_oid_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_OID_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                            const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_OID_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                             const struct dsdb_attribute *attr,
                                             const struct drsuapi_DsReplicaAttribute *in,
                                             TALLOC_CTX *mem_ctx,
                                             struct ldb_message_element *out)
 {
-       switch (attr->attributeID_id) {
-       case DRSUAPI_ATTRIBUTE_objectClass:
-       case DRSUAPI_ATTRIBUTE_subClassOf:
-       case DRSUAPI_ATTRIBUTE_auxiliaryClass:
-       case DRSUAPI_ATTRIBUTE_systemAuxiliaryClass:
-       case DRSUAPI_ATTRIBUTE_systemPossSuperiors:
-       case DRSUAPI_ATTRIBUTE_possSuperiors:
-               return _dsdb_syntax_OID_obj_drsuapi_to_ldb(ldb, schema, attr, in, mem_ctx, out);
-       case DRSUAPI_ATTRIBUTE_systemMustContain:
-       case DRSUAPI_ATTRIBUTE_systemMayContain:        
-       case DRSUAPI_ATTRIBUTE_mustContain:
-       case DRSUAPI_ATTRIBUTE_rDNAttId:
-       case DRSUAPI_ATTRIBUTE_transportAddressAttribute:
-       case DRSUAPI_ATTRIBUTE_mayContain:
-               return _dsdb_syntax_OID_attr_drsuapi_to_ldb(ldb, schema, attr, in, mem_ctx, out);
-       case DRSUAPI_ATTRIBUTE_governsID:
-       case DRSUAPI_ATTRIBUTE_attributeID:
-       case DRSUAPI_ATTRIBUTE_attributeSyntax:
-               return _dsdb_syntax_OID_oid_drsuapi_to_ldb(ldb, schema, attr, in, mem_ctx, out);
-       }
+       WERROR werr;
 
-       DEBUG(0,(__location__ ": Unknown handling for attributeID_id for %s\n",
-                attr->lDAPDisplayName));
-       return _dsdb_syntax_auto_OID_drsuapi_to_ldb(ldb, schema, attr, in, mem_ctx, out);
+       switch (attr->attributeID_id) {
+       case DRSUAPI_ATTID_objectClass:
+       case DRSUAPI_ATTID_subClassOf:
+       case DRSUAPI_ATTID_auxiliaryClass:
+       case DRSUAPI_ATTID_systemAuxiliaryClass:
+       case DRSUAPI_ATTID_systemPossSuperiors:
+       case DRSUAPI_ATTID_possSuperiors:
+               werr = _dsdb_syntax_OID_obj_drsuapi_to_ldb(ctx, attr, in, mem_ctx, out);
+               break;
+       case DRSUAPI_ATTID_systemMustContain:
+       case DRSUAPI_ATTID_systemMayContain:
+       case DRSUAPI_ATTID_mustContain:
+       case DRSUAPI_ATTID_rDNAttId:
+       case DRSUAPI_ATTID_transportAddressAttribute:
+       case DRSUAPI_ATTID_mayContain:
+               werr = _dsdb_syntax_OID_attr_drsuapi_to_ldb(ctx, attr, in, mem_ctx, out);
+               break;
+       case DRSUAPI_ATTID_governsID:
+       case DRSUAPI_ATTID_attributeID:
+       case DRSUAPI_ATTID_attributeSyntax:
+               werr = _dsdb_syntax_OID_oid_drsuapi_to_ldb(ctx, attr, in, mem_ctx, out);
+               break;
+       default:
+               DEBUG(0,(__location__ ": Unknown handling for attributeID_id for %s\n",
+                        attr->lDAPDisplayName));
+               return _dsdb_syntax_auto_OID_drsuapi_to_ldb(ctx, attr, in, mem_ctx, out);
+       }
+
+       /* When we are doing the vampire of a schema, we don't want
+        * the inability to reference an OID to get in the way.
+        * Otherwise, we won't get the new schema with which to
+        * understand this */
+       if (!W_ERROR_IS_OK(werr) && ctx->schema->relax_OID_conversions) {
+               return _dsdb_syntax_OID_oid_drsuapi_to_ldb(ctx, attr, in, mem_ctx, out);
+       }
+       return werr;
 }
 
-static WERROR dsdb_syntax_OID_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                            const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_OID_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                             const struct dsdb_attribute *attr,
                                             const struct ldb_message_element *in,
                                             TALLOC_CTX *mem_ctx,
                                             struct drsuapi_DsReplicaAttribute *out)
 {
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
        switch (attr->attributeID_id) {
-       case DRSUAPI_ATTRIBUTE_objectClass:
-       case DRSUAPI_ATTRIBUTE_subClassOf:
-       case DRSUAPI_ATTRIBUTE_auxiliaryClass:
-       case DRSUAPI_ATTRIBUTE_systemAuxiliaryClass:
-       case DRSUAPI_ATTRIBUTE_systemPossSuperiors:
-       case DRSUAPI_ATTRIBUTE_possSuperiors:
-               return _dsdb_syntax_OID_obj_ldb_to_drsuapi(ldb, schema, attr, in, mem_ctx, out);
-       case DRSUAPI_ATTRIBUTE_systemMustContain:
-       case DRSUAPI_ATTRIBUTE_systemMayContain:        
-       case DRSUAPI_ATTRIBUTE_mustContain:
-       case DRSUAPI_ATTRIBUTE_rDNAttId:
-       case DRSUAPI_ATTRIBUTE_transportAddressAttribute:
-       case DRSUAPI_ATTRIBUTE_mayContain:
-               return _dsdb_syntax_OID_attr_ldb_to_drsuapi(ldb, schema, attr, in, mem_ctx, out);
-       case DRSUAPI_ATTRIBUTE_governsID:
-       case DRSUAPI_ATTRIBUTE_attributeID:
-       case DRSUAPI_ATTRIBUTE_attributeSyntax:
-               return _dsdb_syntax_OID_oid_ldb_to_drsuapi(ldb, schema, attr, in, mem_ctx, out);
+       case DRSUAPI_ATTID_objectClass:
+       case DRSUAPI_ATTID_subClassOf:
+       case DRSUAPI_ATTID_auxiliaryClass:
+       case DRSUAPI_ATTID_systemAuxiliaryClass:
+       case DRSUAPI_ATTID_systemPossSuperiors:
+       case DRSUAPI_ATTID_possSuperiors:
+               return _dsdb_syntax_OID_obj_ldb_to_drsuapi(ctx, attr, in, mem_ctx, out);
+       case DRSUAPI_ATTID_systemMustContain:
+       case DRSUAPI_ATTID_systemMayContain:
+       case DRSUAPI_ATTID_mustContain:
+       case DRSUAPI_ATTID_rDNAttId:
+       case DRSUAPI_ATTID_transportAddressAttribute:
+       case DRSUAPI_ATTID_mayContain:
+               return _dsdb_syntax_OID_attr_ldb_to_drsuapi(ctx, attr, in, mem_ctx, out);
+       case DRSUAPI_ATTID_governsID:
+       case DRSUAPI_ATTID_attributeID:
+       case DRSUAPI_ATTID_attributeSyntax:
+               return _dsdb_syntax_OID_oid_ldb_to_drsuapi(ctx, attr, in, mem_ctx, out);
        }
 
        DEBUG(0,(__location__ ": Unknown handling for attributeID_id for %s\n",
                 attr->lDAPDisplayName));
 
-       return _dsdb_syntax_auto_OID_ldb_to_drsuapi(ldb, schema, attr, in, mem_ctx, out);
+       return _dsdb_syntax_auto_OID_ldb_to_drsuapi(ctx, attr, in, mem_ctx, out);
 }
 
-static WERROR dsdb_syntax_UNICODE_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                                const struct dsdb_schema *schema,
+static WERROR _dsdb_syntax_OID_validate_numericoid(const struct dsdb_syntax_ctx *ctx,
+                                                  const struct dsdb_attribute *attr,
+                                                  const struct ldb_message_element *in)
+{
+       unsigned int i;
+       TALLOC_CTX *tmp_ctx;
+
+       tmp_ctx = talloc_new(ctx->ldb);
+       W_ERROR_HAVE_NO_MEMORY(tmp_ctx);
+
+       for (i=0; i < in->num_values; i++) {
+               DATA_BLOB blob;
+               char *oid_out;
+               const char *oid = (const char*)in->values[i].data;
+
+               if (in->values[i].length == 0) {
+                       talloc_free(tmp_ctx);
+                       return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
+               }
+
+               if (!ber_write_OID_String(tmp_ctx, &blob, oid)) {
+                       DEBUG(0,("ber_write_OID_String() failed for %s\n", oid));
+                       talloc_free(tmp_ctx);
+                       return WERR_INVALID_PARAMETER;
+               }
+
+               if (!ber_read_OID_String(tmp_ctx, blob, &oid_out)) {
+                       DEBUG(0,("ber_read_OID_String() failed for %s\n",
+                                hex_encode_talloc(tmp_ctx, blob.data, blob.length)));
+                       talloc_free(tmp_ctx);
+                       return WERR_INVALID_PARAMETER;
+               }
+
+               if (strcmp(oid, oid_out) != 0) {
+                       talloc_free(tmp_ctx);
+                       return WERR_INVALID_PARAMETER;
+               }
+       }
+
+       talloc_free(tmp_ctx);
+       return WERR_OK;
+}
+
+static WERROR dsdb_syntax_OID_validate_ldb(const struct dsdb_syntax_ctx *ctx,
+                                          const struct dsdb_attribute *attr,
+                                          const struct ldb_message_element *in)
+{
+       WERROR status;
+       struct drsuapi_DsReplicaAttribute drs_tmp;
+       struct ldb_message_element ldb_tmp;
+       TALLOC_CTX *tmp_ctx;
+
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
+               return WERR_FOOBAR;
+       }
+
+       switch (attr->attributeID_id) {
+       case DRSUAPI_ATTID_governsID:
+       case DRSUAPI_ATTID_attributeID:
+       case DRSUAPI_ATTID_attributeSyntax:
+               return _dsdb_syntax_OID_validate_numericoid(ctx, attr, in);
+       }
+
+       /*
+        * TODO: optimize and verify this code
+        */
+
+       tmp_ctx = talloc_new(ctx->ldb);
+       W_ERROR_HAVE_NO_MEMORY(tmp_ctx);
+
+       status = dsdb_syntax_OID_ldb_to_drsuapi(ctx,
+                                               attr,
+                                               in,
+                                               tmp_ctx,
+                                               &drs_tmp);
+       if (!W_ERROR_IS_OK(status)) {
+               talloc_free(tmp_ctx);
+               return status;
+       }
+
+       status = dsdb_syntax_OID_drsuapi_to_ldb(ctx,
+                                               attr,
+                                               &drs_tmp,
+                                               tmp_ctx,
+                                               &ldb_tmp);
+       if (!W_ERROR_IS_OK(status)) {
+               talloc_free(tmp_ctx);
+               return status;
+       }
+
+       talloc_free(tmp_ctx);
+       return WERR_OK;
+}
+
+static WERROR dsdb_syntax_UNICODE_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                 const struct dsdb_attribute *attr,
                                                 const struct drsuapi_DsReplicaAttribute *in,
                                                 TALLOC_CTX *mem_ctx,
                                                 struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -1305,6 +1504,7 @@ static WERROR dsdb_syntax_UNICODE_drsuapi_to_ldb(struct ldb_context *ldb,
        W_ERROR_HAVE_NO_MEMORY(out->values);
 
        for (i=0; i < out->num_values; i++) {
+               size_t converted_size = 0;
                char *str;
 
                if (in->value_ctr.values[i].blob == NULL) {
@@ -1315,12 +1515,11 @@ static WERROR dsdb_syntax_UNICODE_drsuapi_to_ldb(struct ldb_context *ldb,
                        return WERR_FOOBAR;
                }
 
-               if (!convert_string_talloc_convenience(out->values, 
-                                               schema->iconv_convenience, 
-                                                                       CH_UTF16, CH_UNIX,
-                                           in->value_ctr.values[i].blob->data,
-                                           in->value_ctr.values[i].blob->length,
-                                           (void **)&str, NULL, false)) {
+               if (!convert_string_talloc(out->values,
+                                          CH_UTF16, CH_UNIX,
+                                          in->value_ctr.values[i].blob->data,
+                                          in->value_ctr.values[i].blob->length,
+                                          (void **)&str, &converted_size)) {
                        return WERR_FOOBAR;
                }
 
@@ -1330,21 +1529,21 @@ static WERROR dsdb_syntax_UNICODE_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_UNICODE_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                                const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_UNICODE_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                 const struct dsdb_attribute *attr,
                                                 const struct ldb_message_element *in,
                                                 TALLOC_CTX *mem_ctx,
                                                 struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -1357,19 +1556,18 @@ static WERROR dsdb_syntax_UNICODE_ldb_to_drsuapi(struct ldb_context *ldb,
        for (i=0; i < in->num_values; i++) {
                out->value_ctr.values[i].blob   = &blobs[i];
 
-               if (!convert_string_talloc_convenience(blobs,
-                       schema->iconv_convenience, CH_UNIX, CH_UTF16,
-                       in->values[i].data, in->values[i].length,
-                       (void **)&blobs[i].data, &blobs[i].length, false)) {
-                               return WERR_FOOBAR;
+               if (!convert_string_talloc(blobs,
+                                          CH_UNIX, CH_UTF16,
+                                          in->values[i].data, in->values[i].length,
+                                          (void **)&blobs[i].data, &blobs[i].length)) {
+                       return WERR_FOOBAR;
                }
        }
 
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_UNICODE_validate_one_val(struct ldb_context *ldb,
-                                                  const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_UNICODE_validate_one_val(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct ldb_val *val)
 {
@@ -1377,17 +1575,16 @@ static WERROR dsdb_syntax_UNICODE_validate_one_val(struct ldb_context *ldb,
        size_t size;
        bool ok;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       ok = convert_string_talloc_convenience(ldb,
-                                              schema->iconv_convenience,
-                                              CH_UNIX, CH_UTF16,
-                                              val->data,
-                                              val->length,
-                                              (void **)&dst,
-                                              &size, false);
+       ok = convert_string_talloc(ctx->ldb,
+                                  CH_UNIX, CH_UTF16,
+                                  val->data,
+                                  val->length,
+                                  (void **)&dst,
+                                  &size);
        TALLOC_FREE(dst);
        if (!ok) {
                return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
@@ -1408,15 +1605,14 @@ static WERROR dsdb_syntax_UNICODE_validate_one_val(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_UNICODE_validate_ldb(struct ldb_context *ldb,
-                                              const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_UNICODE_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                               const struct dsdb_attribute *attr,
                                               const struct ldb_message_element *in)
 {
        WERROR status;
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
@@ -1425,8 +1621,7 @@ static WERROR dsdb_syntax_UNICODE_validate_ldb(struct ldb_context *ldb,
                        return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
                }
 
-               status = dsdb_syntax_UNICODE_validate_one_val(ldb,
-                                                             schema,
+               status = dsdb_syntax_UNICODE_validate_one_val(ctx,
                                                              attr,
                                                              &in->values[i]);
                if (!W_ERROR_IS_OK(status)) {
@@ -1437,10 +1632,9 @@ static WERROR dsdb_syntax_UNICODE_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-WERROR dsdb_syntax_one_DN_drsuapi_to_ldb(TALLOC_CTX *mem_ctx, struct ldb_context *ldb, 
-                                        const struct dsdb_syntax *syntax, 
-                                        struct smb_iconv_convenience *iconv_convenience,
-                                        const DATA_BLOB *in, DATA_BLOB *out)
+static WERROR dsdb_syntax_one_DN_drsuapi_to_ldb(TALLOC_CTX *mem_ctx, struct ldb_context *ldb,
+                                               const struct dsdb_syntax *syntax,
+                                               const DATA_BLOB *in, DATA_BLOB *out)
 {
        struct drsuapi_DsReplicaObjectIdentifier3 id3;
        enum ndr_err_code ndr_err;
@@ -1453,28 +1647,28 @@ WERROR dsdb_syntax_one_DN_drsuapi_to_ldb(TALLOC_CTX *mem_ctx, struct ldb_context
        if (!tmp_ctx) {
                W_ERROR_HAVE_NO_MEMORY(tmp_ctx);
        }
-       
+
        if (in == NULL) {
                talloc_free(tmp_ctx);
                return WERR_FOOBAR;
        }
-       
+
        if (in->length == 0) {
                talloc_free(tmp_ctx);
                return WERR_FOOBAR;
        }
-       
-       
+
+
        /* windows sometimes sends an extra two pad bytes here */
        ndr_err = ndr_pull_struct_blob(in,
-                                      tmp_ctx, iconv_convenience, &id3,
+                                      tmp_ctx, &id3,
                                       (ndr_pull_flags_fn_t)ndr_pull_drsuapi_DsReplicaObjectIdentifier3);
        if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
                status = ndr_map_error2ntstatus(ndr_err);
                talloc_free(tmp_ctx);
                return ntstatus_to_werror(status);
        }
-       
+
        dn = ldb_dn_new(tmp_ctx, ldb, id3.dn);
        if (!dn) {
                talloc_free(tmp_ctx);
@@ -1488,7 +1682,7 @@ WERROR dsdb_syntax_one_DN_drsuapi_to_ldb(TALLOC_CTX *mem_ctx, struct ldb_context
                        talloc_free(tmp_ctx);
                        return ntstatus_to_werror(status);
                }
-       
+
                ret = ldb_dn_set_extended_component(dn, "GUID", &guid_blob);
                if (ret != LDB_SUCCESS) {
                        talloc_free(tmp_ctx);
@@ -1496,37 +1690,36 @@ WERROR dsdb_syntax_one_DN_drsuapi_to_ldb(TALLOC_CTX *mem_ctx, struct ldb_context
                }
                talloc_free(guid_blob.data);
        }
-       
+
        if (id3.__ndr_size_sid) {
                DATA_BLOB sid_blob;
-               ndr_err = ndr_push_struct_blob(&sid_blob, tmp_ctx, iconv_convenience, &id3.sid,
+               ndr_err = ndr_push_struct_blob(&sid_blob, tmp_ctx, &id3.sid,
                                               (ndr_push_flags_fn_t)ndr_push_dom_sid);
                if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
                        status = ndr_map_error2ntstatus(ndr_err);
                        talloc_free(tmp_ctx);
                        return ntstatus_to_werror(status);
                }
-               
+
                ret = ldb_dn_set_extended_component(dn, "SID", &sid_blob);
                if (ret != LDB_SUCCESS) {
                        talloc_free(tmp_ctx);
                        return WERR_FOOBAR;
                }
        }
-       
+
        *out = data_blob_string_const(ldb_dn_get_extended_linearized(mem_ctx, dn, 1));
        talloc_free(tmp_ctx);
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DN_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                           const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                            const struct dsdb_attribute *attr,
                                            const struct drsuapi_DsReplicaAttribute *in,
                                            TALLOC_CTX *mem_ctx,
                                            struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -1537,34 +1730,33 @@ static WERROR dsdb_syntax_DN_drsuapi_to_ldb(struct ldb_context *ldb,
        W_ERROR_HAVE_NO_MEMORY(out->values);
 
        for (i=0; i < out->num_values; i++) {
-               WERROR status = dsdb_syntax_one_DN_drsuapi_to_ldb(out->values, ldb, attr->syntax, 
-                                                                 schema->iconv_convenience, 
-                                                                 in->value_ctr.values[i].blob, 
+               WERROR status = dsdb_syntax_one_DN_drsuapi_to_ldb(out->values, ctx->ldb, attr->syntax,
+                                                                 in->value_ctr.values[i].blob,
                                                                  &out->values[i]);
                if (!W_ERROR_IS_OK(status)) {
                        return status;
                }
-                                                 
+
        }
 
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DN_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                           const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                            const struct dsdb_attribute *attr,
                                            const struct ldb_message_element *in,
                                            TALLOC_CTX *mem_ctx,
                                            struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -1577,7 +1769,6 @@ static WERROR dsdb_syntax_DN_ldb_to_drsuapi(struct ldb_context *ldb,
        for (i=0; i < in->num_values; i++) {
                struct drsuapi_DsReplicaObjectIdentifier3 id3;
                enum ndr_err_code ndr_err;
-               const DATA_BLOB *sid_blob;
                struct ldb_dn *dn;
                TALLOC_CTX *tmp_ctx = talloc_new(mem_ctx);
                NTSTATUS status;
@@ -1586,7 +1777,7 @@ static WERROR dsdb_syntax_DN_ldb_to_drsuapi(struct ldb_context *ldb,
 
                out->value_ctr.values[i].blob   = &blobs[i];
 
-               dn = ldb_dn_from_ldb_val(tmp_ctx, ldb, &in->values[i]);
+               dn = ldb_dn_from_ldb_val(tmp_ctx, ctx->ldb, &in->values[i]);
 
                W_ERROR_HAVE_NO_MEMORY(dn);
 
@@ -1599,22 +1790,16 @@ static WERROR dsdb_syntax_DN_ldb_to_drsuapi(struct ldb_context *ldb,
                        return ntstatus_to_werror(status);
                }
 
-               sid_blob = ldb_dn_get_extended_component(dn, "SID");
-               if (sid_blob) {
-                       
-                       ndr_err = ndr_pull_struct_blob_all(sid_blob, 
-                                                          tmp_ctx, schema->iconv_convenience, &id3.sid,
-                                                          (ndr_pull_flags_fn_t)ndr_pull_dom_sid);
-                       if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
-                               status = ndr_map_error2ntstatus(ndr_err);
-                               talloc_free(tmp_ctx);
-                               return ntstatus_to_werror(status);
-                       }
+               status = dsdb_get_extended_dn_sid(dn, &id3.sid, "SID");
+               if (!NT_STATUS_IS_OK(status) &&
+                   !NT_STATUS_EQUAL(status, NT_STATUS_OBJECT_NAME_NOT_FOUND)) {
+                       talloc_free(tmp_ctx);
+                       return ntstatus_to_werror(status);
                }
 
                id3.dn = ldb_dn_get_linearized(dn);
 
-               ndr_err = ndr_push_struct_blob(&blobs[i], blobs, schema->iconv_convenience, &id3, (ndr_push_flags_fn_t)ndr_push_drsuapi_DsReplicaObjectIdentifier3);
+               ndr_err = ndr_push_struct_blob(&blobs[i], blobs, &id3, (ndr_push_flags_fn_t)ndr_push_drsuapi_DsReplicaObjectIdentifier3);
                if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
                        status = ndr_map_error2ntstatus(ndr_err);
                        talloc_free(tmp_ctx);
@@ -1626,8 +1811,7 @@ static WERROR dsdb_syntax_DN_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DN_validate_one_val(struct ldb_context *ldb,
-                                             const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_validate_one_val(const struct dsdb_syntax_ctx *ctx,
                                              const struct dsdb_attribute *attr,
                                              const struct ldb_val *val,
                                              TALLOC_CTX *mem_ctx,
@@ -1649,11 +1833,11 @@ static WERROR dsdb_syntax_DN_validate_one_val(struct ldb_context *ldb,
 
        W_ERROR_HAVE_NO_MEMORY(tmp_ctx);
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       dsdb_dn = dsdb_dn_parse(tmp_ctx, ldb, val,
+       dsdb_dn = dsdb_dn_parse(tmp_ctx, ctx->ldb, val,
                                attr->syntax->ldap_oid);
        if (!dsdb_dn) {
                talloc_free(tmp_ctx);
@@ -1682,7 +1866,6 @@ static WERROR dsdb_syntax_DN_validate_one_val(struct ldb_context *ldb,
                num_components++;
                ndr_err = ndr_pull_struct_blob_all(sid_blob,
                                                   tmp_ctx,
-                                                  schema->iconv_convenience,
                                                   &sid,
                                                   (ndr_pull_flags_fn_t)ndr_pull_dom_sid);
                if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
@@ -1705,7 +1888,6 @@ static WERROR dsdb_syntax_DN_validate_one_val(struct ldb_context *ldb,
         * one.
         */
        ldb_dn_extended_filter(dn, extended_list);
-       ldb_dn_remove_extended_components(dn2);
 
        dn_str = ldb_dn_get_extended_linearized(tmp_ctx, dn, 0);
        if (dn_str == NULL) {
@@ -1728,25 +1910,23 @@ static WERROR dsdb_syntax_DN_validate_one_val(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DN_validate_ldb(struct ldb_context *ldb,
-                                         const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                          const struct dsdb_attribute *attr,
                                          const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
        for (i=0; i < in->num_values; i++) {
                WERROR status;
                struct dsdb_dn *dsdb_dn;
-               TALLOC_CTX *tmp_ctx = talloc_new(ldb);
+               TALLOC_CTX *tmp_ctx = talloc_new(ctx->ldb);
                W_ERROR_HAVE_NO_MEMORY(tmp_ctx);
 
-               status = dsdb_syntax_DN_validate_one_val(ldb,
-                                                        schema,
+               status = dsdb_syntax_DN_validate_one_val(ctx,
                                                         attr,
                                                         &in->values[i],
                                                         tmp_ctx, &dsdb_dn);
@@ -1766,14 +1946,13 @@ static WERROR dsdb_syntax_DN_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DN_BINARY_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                                  const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_BINARY_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct drsuapi_DsReplicaAttribute *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
        int ret;
 
        out->flags      = 0;
@@ -1806,10 +1985,10 @@ static WERROR dsdb_syntax_DN_BINARY_drsuapi_to_ldb(struct ldb_context *ldb,
                        return WERR_FOOBAR;
                }
 
-               
+
                /* windows sometimes sends an extra two pad bytes here */
                ndr_err = ndr_pull_struct_blob(in->value_ctr.values[i].blob,
-                                              tmp_ctx, schema->iconv_convenience, &id3,
+                                              tmp_ctx, &id3,
                                               (ndr_pull_flags_fn_t)ndr_pull_drsuapi_DsReplicaObjectIdentifier3Binary);
                if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
                        status = ndr_map_error2ntstatus(ndr_err);
@@ -1817,30 +1996,31 @@ static WERROR dsdb_syntax_DN_BINARY_drsuapi_to_ldb(struct ldb_context *ldb,
                        return ntstatus_to_werror(status);
                }
 
-               dn = ldb_dn_new(tmp_ctx, ldb, id3.dn);
+               dn = ldb_dn_new(tmp_ctx, ctx->ldb, id3.dn);
                if (!dn) {
                        talloc_free(tmp_ctx);
                        /* If this fails, it must be out of memory, as it does not do much parsing */
                        W_ERROR_HAVE_NO_MEMORY(dn);
                }
 
-               status = GUID_to_ndr_blob(&id3.guid, tmp_ctx, &guid_blob);
-               if (!NT_STATUS_IS_OK(status)) {
-                       talloc_free(tmp_ctx);
-                       return ntstatus_to_werror(status);
-               }
+               if (!GUID_all_zero(&id3.guid)) {
+                       status = GUID_to_ndr_blob(&id3.guid, tmp_ctx, &guid_blob);
+                       if (!NT_STATUS_IS_OK(status)) {
+                               talloc_free(tmp_ctx);
+                               return ntstatus_to_werror(status);
+                       }
 
-               ret = ldb_dn_set_extended_component(dn, "GUID", &guid_blob);
-               if (ret != LDB_SUCCESS) {
-                       talloc_free(tmp_ctx);
-                       return WERR_FOOBAR;
+                       ret = ldb_dn_set_extended_component(dn, "GUID", &guid_blob);
+                       if (ret != LDB_SUCCESS) {
+                               talloc_free(tmp_ctx);
+                               return WERR_FOOBAR;
+                       }
+                       talloc_free(guid_blob.data);
                }
 
-               talloc_free(guid_blob.data);
-
                if (id3.__ndr_size_sid) {
                        DATA_BLOB sid_blob;
-                       ndr_err = ndr_push_struct_blob(&sid_blob, tmp_ctx, schema->iconv_convenience, &id3.sid,
+                       ndr_err = ndr_push_struct_blob(&sid_blob, tmp_ctx, &id3.sid,
                                                       (ndr_push_flags_fn_t)ndr_push_dom_sid);
                        if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
                                status = ndr_map_error2ntstatus(ndr_err);
@@ -1869,21 +2049,21 @@ static WERROR dsdb_syntax_DN_BINARY_drsuapi_to_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DN_BINARY_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                                  const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_BINARY_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct ldb_message_element *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -1905,7 +2085,7 @@ static WERROR dsdb_syntax_DN_BINARY_ldb_to_drsuapi(struct ldb_context *ldb,
 
                out->value_ctr.values[i].blob   = &blobs[i];
 
-               dsdb_dn = dsdb_dn_parse(tmp_ctx, ldb, &in->values[i], attr->syntax->ldap_oid);
+               dsdb_dn = dsdb_dn_parse(tmp_ctx, ctx->ldb, &in->values[i], attr->syntax->ldap_oid);
 
                if (!dsdb_dn) {
                        talloc_free(tmp_ctx);
@@ -1923,9 +2103,9 @@ static WERROR dsdb_syntax_DN_BINARY_ldb_to_drsuapi(struct ldb_context *ldb,
 
                sid_blob = ldb_dn_get_extended_component(dsdb_dn->dn, "SID");
                if (sid_blob) {
-                       
-                       ndr_err = ndr_pull_struct_blob_all(sid_blob, 
-                                                          tmp_ctx, schema->iconv_convenience, &id3.sid,
+
+                       ndr_err = ndr_pull_struct_blob_all(sid_blob,
+                                                          tmp_ctx, &id3.sid,
                                                           (ndr_pull_flags_fn_t)ndr_pull_dom_sid);
                        if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
                                status = ndr_map_error2ntstatus(ndr_err);
@@ -1939,7 +2119,7 @@ static WERROR dsdb_syntax_DN_BINARY_ldb_to_drsuapi(struct ldb_context *ldb,
                /* get binary stuff */
                id3.binary = dsdb_dn->extra_part;
 
-               ndr_err = ndr_push_struct_blob(&blobs[i], blobs, schema->iconv_convenience, &id3, (ndr_push_flags_fn_t)ndr_push_drsuapi_DsReplicaObjectIdentifier3Binary);
+               ndr_err = ndr_push_struct_blob(&blobs[i], blobs, &id3, (ndr_push_flags_fn_t)ndr_push_drsuapi_DsReplicaObjectIdentifier3Binary);
                if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err)) {
                        status = ndr_map_error2ntstatus(ndr_err);
                        talloc_free(tmp_ctx);
@@ -1951,25 +2131,23 @@ static WERROR dsdb_syntax_DN_BINARY_ldb_to_drsuapi(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DN_BINARY_validate_ldb(struct ldb_context *ldb,
-                                                const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_BINARY_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                                 const struct dsdb_attribute *attr,
                                                 const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
        for (i=0; i < in->num_values; i++) {
                WERROR status;
                struct dsdb_dn *dsdb_dn;
-               TALLOC_CTX *tmp_ctx = talloc_new(ldb);
+               TALLOC_CTX *tmp_ctx = talloc_new(ctx->ldb);
                W_ERROR_HAVE_NO_MEMORY(tmp_ctx);
 
-               status = dsdb_syntax_DN_validate_one_val(ldb,
-                                                        schema,
+               status = dsdb_syntax_DN_validate_one_val(ctx,
                                                         attr,
                                                         &in->values[i],
                                                         tmp_ctx, &dsdb_dn);
@@ -1983,8 +2161,7 @@ static WERROR dsdb_syntax_DN_BINARY_validate_ldb(struct ldb_context *ldb,
                        return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
                }
 
-               status = dsdb_syntax_DATA_BLOB_validate_one_val(ldb,
-                                                               schema,
+               status = dsdb_syntax_DATA_BLOB_validate_one_val(ctx,
                                                                attr,
                                                                &dsdb_dn->extra_part);
                if (!W_ERROR_IS_OK(status)) {
@@ -1998,55 +2175,49 @@ static WERROR dsdb_syntax_DN_BINARY_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_DN_STRING_drsuapi_to_ldb(struct ldb_context *ldb,
-                                                  const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_STRING_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct drsuapi_DsReplicaAttribute *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct ldb_message_element *out)
 {
-       return dsdb_syntax_DN_BINARY_drsuapi_to_ldb(ldb,
-                                                   schema,
+       return dsdb_syntax_DN_BINARY_drsuapi_to_ldb(ctx,
                                                    attr,
                                                    in,
                                                    mem_ctx,
                                                    out);
 }
 
-static WERROR dsdb_syntax_DN_STRING_ldb_to_drsuapi(struct ldb_context *ldb,
-                                                  const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_STRING_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                   const struct dsdb_attribute *attr,
                                                   const struct ldb_message_element *in,
                                                   TALLOC_CTX *mem_ctx,
                                                   struct drsuapi_DsReplicaAttribute *out)
 {
-       return dsdb_syntax_DN_BINARY_ldb_to_drsuapi(ldb,
-                                                   schema,
+       return dsdb_syntax_DN_BINARY_ldb_to_drsuapi(ctx,
                                                    attr,
                                                    in,
                                                    mem_ctx,
                                                    out);
 }
 
-static WERROR dsdb_syntax_DN_STRING_validate_ldb(struct ldb_context *ldb,
-                                                const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_DN_STRING_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                                 const struct dsdb_attribute *attr,
                                                 const struct ldb_message_element *in)
 {
-       uint32_t i;
+       unsigned int i;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
        for (i=0; i < in->num_values; i++) {
                WERROR status;
                struct dsdb_dn *dsdb_dn;
-               TALLOC_CTX *tmp_ctx = talloc_new(ldb);
+               TALLOC_CTX *tmp_ctx = talloc_new(ctx->ldb);
                W_ERROR_HAVE_NO_MEMORY(tmp_ctx);
 
-               status = dsdb_syntax_DN_validate_one_val(ldb,
-                                                        schema,
+               status = dsdb_syntax_DN_validate_one_val(ctx,
                                                         attr,
                                                         &in->values[i],
                                                         tmp_ctx, &dsdb_dn);
@@ -2060,8 +2231,7 @@ static WERROR dsdb_syntax_DN_STRING_validate_ldb(struct ldb_context *ldb,
                        return WERR_DS_INVALID_ATTRIBUTE_SYNTAX;
                }
 
-               status = dsdb_syntax_UNICODE_validate_one_val(ldb,
-                                                             schema,
+               status = dsdb_syntax_UNICODE_validate_one_val(ctx,
                                                              attr,
                                                              &dsdb_dn->extra_part);
                if (!W_ERROR_IS_OK(status)) {
@@ -2075,14 +2245,13 @@ static WERROR dsdb_syntax_DN_STRING_validate_ldb(struct ldb_context *ldb,
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_PRESENTATION_ADDRESS_drsuapi_to_ldb(struct ldb_context *ldb, 
-                                                             const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_PRESENTATION_ADDRESS_drsuapi_to_ldb(const struct dsdb_syntax_ctx *ctx,
                                                              const struct dsdb_attribute *attr,
                                                              const struct drsuapi_DsReplicaAttribute *in,
                                                              TALLOC_CTX *mem_ctx,
                                                              struct ldb_message_element *out)
 {
-       uint32_t i;
+       unsigned int i;
 
        out->flags      = 0;
        out->name       = talloc_strdup(mem_ctx, attr->lDAPDisplayName);
@@ -2093,7 +2262,8 @@ static WERROR dsdb_syntax_PRESENTATION_ADDRESS_drsuapi_to_ldb(struct ldb_context
        W_ERROR_HAVE_NO_MEMORY(out->values);
 
        for (i=0; i < out->num_values; i++) {
-               uint32_t len;
+               size_t len;
+               size_t converted_size = 0;
                char *str;
 
                if (in->value_ctr.values[i].blob == NULL) {
@@ -2110,10 +2280,10 @@ static WERROR dsdb_syntax_PRESENTATION_ADDRESS_drsuapi_to_ldb(struct ldb_context
                        return WERR_FOOBAR;
                }
 
-               if (!convert_string_talloc_convenience(out->values, schema->iconv_convenience, CH_UTF16, CH_UNIX,
-                                           in->value_ctr.values[i].blob->data+4,
-                                           in->value_ctr.values[i].blob->length-4,
-                                           (void **)&str, NULL, false)) {
+               if (!convert_string_talloc(out->values, CH_UTF16, CH_UNIX,
+                                          in->value_ctr.values[i].blob->data+4,
+                                          in->value_ctr.values[i].blob->length-4,
+                                          (void **)&str, &converted_size)) {
                        return WERR_FOOBAR;
                }
 
@@ -2123,21 +2293,21 @@ static WERROR dsdb_syntax_PRESENTATION_ADDRESS_drsuapi_to_ldb(struct ldb_context
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_PRESENTATION_ADDRESS_ldb_to_drsuapi(struct ldb_context *ldb, 
-                                                             const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_PRESENTATION_ADDRESS_ldb_to_drsuapi(const struct dsdb_syntax_ctx *ctx,
                                                              const struct dsdb_attribute *attr,
                                                              const struct ldb_message_element *in,
                                                              TALLOC_CTX *mem_ctx,
                                                              struct drsuapi_DsReplicaAttribute *out)
 {
-       uint32_t i;
+       unsigned int i;
        DATA_BLOB *blobs;
 
-       if (attr->attributeID_id == 0xFFFFFFFF) {
+       if (attr->attributeID_id == DRSUAPI_ATTID_INVALID) {
                return WERR_FOOBAR;
        }
 
-       out->attid                      = attr->attributeID_id;
+       out->attid                      = dsdb_attribute_get_attid(attr,
+                                                                  ctx->is_schema_nc);
        out->value_ctr.num_values       = in->num_values;
        out->value_ctr.values           = talloc_array(mem_ctx,
                                                       struct drsuapi_DsAttributeValue,
@@ -2153,10 +2323,10 @@ static WERROR dsdb_syntax_PRESENTATION_ADDRESS_ldb_to_drsuapi(struct ldb_context
 
                out->value_ctr.values[i].blob   = &blobs[i];
 
-               if (!convert_string_talloc_convenience(blobs, schema->iconv_convenience, CH_UNIX, CH_UTF16,
-                                           in->values[i].data,
-                                           in->values[i].length,
-                                           (void **)&data, &ret, false)) {
+               if (!convert_string_talloc(blobs, CH_UNIX, CH_UTF16,
+                                          in->values[i].data,
+                                          in->values[i].length,
+                                          (void **)&data, &ret)) {
                        return WERR_FOOBAR;
                }
 
@@ -2174,13 +2344,11 @@ static WERROR dsdb_syntax_PRESENTATION_ADDRESS_ldb_to_drsuapi(struct ldb_context
        return WERR_OK;
 }
 
-static WERROR dsdb_syntax_PRESENTATION_ADDRESS_validate_ldb(struct ldb_context *ldb,
-                                                           const struct dsdb_schema *schema,
+static WERROR dsdb_syntax_PRESENTATION_ADDRESS_validate_ldb(const struct dsdb_syntax_ctx *ctx,
                                                            const struct dsdb_attribute *attr,
                                                            const struct ldb_message_element *in)
 {
-       return dsdb_syntax_UNICODE_validate_ldb(ldb,
-                                               schema,
+       return dsdb_syntax_UNICODE_validate_ldb(ctx,
                                                attr,
                                                in);
 }
@@ -2197,7 +2365,8 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
                .ldb_to_drsuapi         = dsdb_syntax_BOOL_ldb_to_drsuapi,
                .validate_ldb           = dsdb_syntax_BOOL_validate_ldb,
                .equality               = "booleanMatch",
-               .comment                = "Boolean" 
+               .comment                = "Boolean",
+               .auto_normalise         = true
        },{
                .name                   = "Integer",
                .ldap_oid               = LDB_SYNTAX_INTEGER,
@@ -2208,7 +2377,8 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
                .validate_ldb           = dsdb_syntax_INT32_validate_ldb,
                .equality               = "integerMatch",
                .comment                = "Integer",
-               .ldb_syntax             = LDB_SYNTAX_SAMBA_INT32
+               .ldb_syntax             = LDB_SYNTAX_SAMBA_INT32,
+               .auto_normalise         = true
        },{
                .name                   = "String(Octet)",
                .ldap_oid               = LDB_SYNTAX_OCTET_STRING,
@@ -2237,7 +2407,7 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
                .attributeSyntax_oid    = "2.5.5.2",
                .drsuapi_to_ldb         = dsdb_syntax_OID_drsuapi_to_ldb,
                .ldb_to_drsuapi         = dsdb_syntax_OID_ldb_to_drsuapi,
-               .validate_ldb           = dsdb_syntax_ALLOW_validate_ldb,
+               .validate_ldb           = dsdb_syntax_OID_validate_ldb,
                .equality               = "caseIgnoreMatch", /* Would use "objectIdentifierMatch" but most are ldap attribute/class names */
                .comment                = "OID String",
                .ldb_syntax             = LDB_SYNTAX_DIRECTORY_STRING
@@ -2249,7 +2419,8 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
                .drsuapi_to_ldb         = dsdb_syntax_INT32_drsuapi_to_ldb,
                .ldb_to_drsuapi         = dsdb_syntax_INT32_ldb_to_drsuapi,
                .validate_ldb           = dsdb_syntax_INT32_validate_ldb,
-               .ldb_syntax             = LDB_SYNTAX_SAMBA_INT32
+               .ldb_syntax             = LDB_SYNTAX_SAMBA_INT32,
+               .auto_normalise         = true
        },{
        /* not used in w2k3 forest */
                .name                   = "String(Numeric)",
@@ -2305,6 +2476,7 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
                .validate_ldb           = dsdb_syntax_NTTIME_UTC_validate_ldb,
                .equality               = "generalizedTimeMatch",
                .comment                = "UTC Time",
+               .auto_normalise         = true
        },{
                .name                   = "String(Generalized-Time)",
                .ldap_oid               = "1.3.6.1.4.1.1466.115.121.1.24",
@@ -2316,15 +2488,23 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
                .equality               = "generalizedTimeMatch",
                .comment                = "Generalized Time",
                .ldb_syntax             = LDB_SYNTAX_UTC_TIME,
+               .auto_normalise         = true
        },{
        /* not used in w2k3 schema */
                .name                   = "String(Case Sensitive)",
                .ldap_oid               = "1.2.840.113556.1.4.1362",
                .oMSyntax               = 27,
                .attributeSyntax_oid    = "2.5.5.3",
-               .drsuapi_to_ldb         = dsdb_syntax_FOOBAR_drsuapi_to_ldb,
-               .ldb_to_drsuapi         = dsdb_syntax_FOOBAR_ldb_to_drsuapi,
-               .validate_ldb           = dsdb_syntax_FOOBAR_validate_ldb,
+               .drsuapi_to_ldb         = dsdb_syntax_DATA_BLOB_drsuapi_to_ldb,
+               .ldb_to_drsuapi         = dsdb_syntax_DATA_BLOB_ldb_to_drsuapi,
+               .validate_ldb           = dsdb_syntax_DATA_BLOB_validate_ldb,
+               .equality               = "caseExactMatch",
+               .substring              = "caseExactSubstringsMatch",
+               /* TODO (kim): according to LDAP rfc we should be using same comparison
+                * as Directory String (LDB_SYNTAX_DIRECTORY_STRING), but case sensitive.
+                * But according to ms docs binary compare should do the job:
+                * http://msdn.microsoft.com/en-us/library/cc223200(v=PROT.10).aspx */
+               .ldb_syntax             = LDB_SYNTAX_OCTET_STRING,
        },{
                .name                   = "String(Unicode)",
                .ldap_oid               = LDB_SYNTAX_DIRECTORY_STRING,
@@ -2347,6 +2527,7 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
                .equality               = "integerMatch",
                .comment                = "Large Integer",
                .ldb_syntax             = LDB_SYNTAX_INTEGER,
+               .auto_normalise         = true
        },{
                .name                   = "String(NT-Sec-Desc)",
                .ldap_oid               = LDB_SYNTAX_SAMBA_SECURITY_DESCRIPTOR,
@@ -2390,11 +2571,11 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
                .equality               = "caseIgnoreMatch",
                .ldb_syntax             = LDB_SYNTAX_DN,
        },{
-       /* 
+       /*
         * TODO: verify if DATA_BLOB is correct here...!
         *
         *       repsFrom and repsTo are the only attributes using
-        *       this attribute syntax, but they're not replicated... 
+        *       this attribute syntax, but they're not replicated...
         */
                .name                   = "Object(Replica-Link)",
                .ldap_oid               = "1.3.6.1.4.1.1466.115.121.1.40",
@@ -2441,9 +2622,9 @@ static const struct dsdb_syntax dsdb_syntaxes[] = {
        }
 };
 
-const struct dsdb_syntax *find_syntax_map_by_ad_oid(const char *ad_oid) 
+const struct dsdb_syntax *find_syntax_map_by_ad_oid(const char *ad_oid)
 {
-       int i;
+       unsigned int i;
        for (i=0; dsdb_syntaxes[i].ldap_oid; i++) {
                if (strcasecmp(ad_oid, dsdb_syntaxes[i].attributeSyntax_oid) == 0) {
                        return &dsdb_syntaxes[i];
@@ -2452,9 +2633,9 @@ const struct dsdb_syntax *find_syntax_map_by_ad_oid(const char *ad_oid)
        return NULL;
 }
 
-const struct dsdb_syntax *find_syntax_map_by_ad_syntax(int oMSyntax) 
+const struct dsdb_syntax *find_syntax_map_by_ad_syntax(int oMSyntax)
 {
-       int i;
+       unsigned int i;
        for (i=0; dsdb_syntaxes[i].ldap_oid; i++) {
                if (oMSyntax == dsdb_syntaxes[i].oMSyntax) {
                        return &dsdb_syntaxes[i];
@@ -2463,9 +2644,9 @@ const struct dsdb_syntax *find_syntax_map_by_ad_syntax(int oMSyntax)
        return NULL;
 }
 
-const struct dsdb_syntax *find_syntax_map_by_standard_oid(const char *standard_oid) 
+const struct dsdb_syntax *find_syntax_map_by_standard_oid(const char *standard_oid)
 {
-       int i;
+       unsigned int i;
        for (i=0; dsdb_syntaxes[i].ldap_oid; i++) {
                if (strcasecmp(standard_oid, dsdb_syntaxes[i].ldap_oid) == 0) {
                        return &dsdb_syntaxes[i];
@@ -2473,9 +2654,10 @@ const struct dsdb_syntax *find_syntax_map_by_standard_oid(const char *standard_o
        }
        return NULL;
 }
+
 const struct dsdb_syntax *dsdb_syntax_for_attribute(const struct dsdb_attribute *attr)
 {
-       uint32_t i;
+       unsigned int i;
 
        for (i=0; i < ARRAY_SIZE(dsdb_syntaxes); i++) {
                if (attr->oMSyntax != dsdb_syntaxes[i].oMSyntax) continue;
@@ -2498,48 +2680,67 @@ const struct dsdb_syntax *dsdb_syntax_for_attribute(const struct dsdb_attribute
        return NULL;
 }
 
-WERROR dsdb_attribute_drsuapi_to_ldb(struct ldb_context *ldb, 
+WERROR dsdb_attribute_drsuapi_to_ldb(struct ldb_context *ldb,
                                     const struct dsdb_schema *schema,
+                                    const struct dsdb_schema_prefixmap *pfm_remote,
                                     const struct drsuapi_DsReplicaAttribute *in,
                                     TALLOC_CTX *mem_ctx,
                                     struct ldb_message_element *out)
 {
        const struct dsdb_attribute *sa;
+       struct dsdb_syntax_ctx syntax_ctx;
+       uint32_t attid_local;
+
+       /* use default syntax conversion context */
+       dsdb_syntax_ctx_init(&syntax_ctx, ldb, schema);
+       syntax_ctx.pfm_remote = pfm_remote;
+
+       switch (dsdb_pfm_get_attid_type(in->attid)) {
+       case DSDB_ATTID_TYPE_PFM:
+               /* map remote ATTID to local ATTID */
+               if (!dsdb_syntax_attid_from_remote_attid(&syntax_ctx, mem_ctx, in->attid, &attid_local)) {
+                       DEBUG(0,(__location__ ": Can't find local ATTID for 0x%08X\n",
+                                in->attid));
+                       return WERR_FOOBAR;
+               }
+               break;
+       case DSDB_ATTID_TYPE_INTID:
+               /* use IntId value directly */
+               attid_local = in->attid;
+               break;
+       default:
+               /* we should never get here */
+               DEBUG(0,(__location__ ": Invalid ATTID type passed for conversion - 0x%08X\n",
+                        in->attid));
+               return WERR_INVALID_PARAMETER;
+       }
 
-       sa = dsdb_attribute_by_attributeID_id(schema, in->attid);
+       sa = dsdb_attribute_by_attributeID_id(schema, attid_local);
        if (!sa) {
+               DEBUG(1,(__location__ ": Unknown attributeID_id 0x%08X\n", in->attid));
                return WERR_FOOBAR;
        }
 
-       return sa->syntax->drsuapi_to_ldb(ldb, schema, sa, in, mem_ctx, out);
+       return sa->syntax->drsuapi_to_ldb(&syntax_ctx, sa, in, mem_ctx, out);
 }
 
-WERROR dsdb_attribute_ldb_to_drsuapi(struct ldb_context *ldb, 
+WERROR dsdb_attribute_ldb_to_drsuapi(struct ldb_context *ldb,
                                     const struct dsdb_schema *schema,
                                     const struct ldb_message_element *in,
                                     TALLOC_CTX *mem_ctx,
                                     struct drsuapi_DsReplicaAttribute *out)
 {
        const struct dsdb_attribute *sa;
+       struct dsdb_syntax_ctx syntax_ctx;
 
        sa = dsdb_attribute_by_lDAPDisplayName(schema, in->name);
        if (!sa) {
                return WERR_FOOBAR;
        }
 
-       return sa->syntax->ldb_to_drsuapi(ldb, schema, sa, in, mem_ctx, out);
-}
-
-WERROR dsdb_attribute_validate_ldb(struct ldb_context *ldb,
-                                  const struct dsdb_schema *schema,
-                                  const struct ldb_message_element *in)
-{
-       const struct dsdb_attribute *sa;
+       /* use default syntax conversion context */
+       dsdb_syntax_ctx_init(&syntax_ctx, ldb, schema);
 
-       sa = dsdb_attribute_by_lDAPDisplayName(schema, in->name);
-       if (!sa) {
-               return WERR_DS_ATTRIBUTE_TYPE_UNDEFINED;
-       }
-
-       return sa->syntax->validate_ldb(ldb, schema, sa, in);
+       return sa->syntax->ldb_to_drsuapi(&syntax_ctx, sa, in, mem_ctx, out);
 }
+