From 6fe479a210adb53d419ca75512dec3a584296289 Mon Sep 17 00:00:00 2001

From: =?UTF-8?q?Pavel=20B=C5=99ezina?= <pbrezina@redhat.com>

Date: Tue, 13 Aug 2019 13:00:23 +0200

Subject: [PATCH 77/90] cache_req: add autofs entry by name plugin

MIME-Version: 1.0

Content-Type: text/plain; charset=UTF-8

Content-Transfer-Encoding: 8bit

We will use the current data provider call that downloads all map entries

but we will replace it later when new call is available.

Resolves:

https://pagure.io/SSSD/sssd/issue/2607

Reviewed-by: Tomáš Halman <thalman@redhat.com>

---

 Makefile.am                                   |   1 +

 src/responder/common/cache_req/cache_req.c    |   3 +-

 src/responder/common/cache_req/cache_req.h    |  21 +++

 .../common/cache_req/cache_req_data.c         |  33 +++++

 .../common/cache_req/cache_req_plugin.h       |   1 +

 .../common/cache_req/cache_req_private.h      |   1 +

 .../plugins/cache_req_autofs_entry_by_name.c  | 129 ++++++++++++++++++

 src/tests/cwrap/Makefile.am                   |   1 +

 8 files changed, 189 insertions(+), 1 deletion(-)

 create mode 100644 src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c

diff --git a/Makefile.am b/Makefile.am

index 461a9355f..bc74906a7 100644

--- a/Makefile.am

+++ b/Makefile.am

@@ -561,6 +561,7 @@ SSSD_CACHE_REQ_OBJ = \

 	src/responder/common/cache_req/plugins/cache_req_host_by_name.c \

 	src/responder/common/cache_req/plugins/cache_req_autofs_map_entries.c \

 	src/responder/common/cache_req/plugins/cache_req_autofs_map_by_name.c \

+	src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c \

 	$(NULL)

 SSSD_RESPONDER_IFACE_OBJ = \

diff --git a/src/responder/common/cache_req/cache_req.c b/src/responder/common/cache_req/cache_req.c

index 75f396a23..febca2468 100644

--- a/src/responder/common/cache_req/cache_req.c

+++ b/src/responder/common/cache_req/cache_req.c

@@ -62,7 +62,8 @@ cache_req_get_plugin(enum cache_req_type type)

         &cache_req_host_by_name,

         &cache_req_autofs_map_entries,

-        &cache_req_autofs_map_by_name

+        &cache_req_autofs_map_by_name,

+        &cache_req_autofs_entry_by_name

     };

     if (type >= CACHE_REQ_SENTINEL) {

diff --git a/src/responder/common/cache_req/cache_req.h b/src/responder/common/cache_req/cache_req.h

index 66a13445c..412f6221b 100644

--- a/src/responder/common/cache_req/cache_req.h

+++ b/src/responder/common/cache_req/cache_req.h

@@ -56,6 +56,7 @@ enum cache_req_type {

     CACHE_REQ_AUTOFS_MAP_ENTRIES,

     CACHE_REQ_AUTOFS_MAP_BY_NAME,

+    CACHE_REQ_AUTOFS_ENTRY_BY_NAME,

     CACHE_REQ_SENTINEL

 };

@@ -126,6 +127,13 @@ cache_req_data_host(TALLOC_CTX *mem_ctx,

                     const char *name,

                     const char *alias,

                     const char **attrs);

+

+struct cache_req_data *

+cache_req_data_autofs_entry(TALLOC_CTX *mem_ctx,

+                            enum cache_req_type type,

+                            const char *mapname,

+                            const char *entryname);

+

 void

 cache_req_data_set_bypass_cache(struct cache_req_data *data,

                                 bool bypass_cache);

@@ -457,4 +465,17 @@ cache_req_autofs_map_by_name_send(TALLOC_CTX *mem_ctx,

 #define cache_req_autofs_map_by_name_recv(mem_ctx, req, _result) \

     cache_req_single_domain_recv(mem_ctx, req, _result)

+struct tevent_req *

+cache_req_autofs_entry_by_name_send(TALLOC_CTX *mem_ctx,

+                                    struct tevent_context *ev,

+                                    struct resp_ctx *rctx,

+                                    struct sss_nc_ctx *ncache,

+                                    int cache_refresh_percent,

+                                    const char *domain,

+                                    const char *mapname,

+                                    const char *entryname);

+

+#define cache_req_autofs_entry_by_name_recv(mem_ctx, req, _result) \

+    cache_req_single_domain_recv(mem_ctx, req, _result)

+

 #endif /* _CACHE_REQ_H_ */

diff --git a/src/responder/common/cache_req/cache_req_data.c b/src/responder/common/cache_req/cache_req_data.c

index ad6176641..01eeedbc4 100644

--- a/src/responder/common/cache_req/cache_req_data.c

+++ b/src/responder/common/cache_req/cache_req_data.c

@@ -209,6 +209,25 @@ cache_req_data_create(TALLOC_CTX *mem_ctx,

             goto done;

         }

         break;

+    case CACHE_REQ_AUTOFS_ENTRY_BY_NAME:

+        if (input->name.input == NULL) {

+            DEBUG(SSSDBG_CRIT_FAILURE, "Bug: name cannot be NULL!\n");

+            ret = ERR_INTERNAL;

+            goto done;

+        }

+

+        data->name.input = talloc_strdup(data, input->name.input);

+        if (data->name.input == NULL) {

+            ret = ENOMEM;

+            goto done;

+        }

+

+        data->autofs_entry_name = talloc_strdup(data, input->autofs_entry_name);

+        if (data->autofs_entry_name == NULL) {

+            ret = ENOMEM;

+            goto done;

+        }

+        break;

     case CACHE_REQ_SENTINEL:

         DEBUG(SSSDBG_CRIT_FAILURE, "Invalid cache request type!\n");

         ret = ERR_INTERNAL;

@@ -356,6 +375,20 @@ cache_req_data_host(TALLOC_CTX *mem_ctx,

     return cache_req_data_create(mem_ctx, type, &input);

 }

+struct cache_req_data *

+cache_req_data_autofs_entry(TALLOC_CTX *mem_ctx,

+                            enum cache_req_type type,

+                            const char *mapname,

+                            const char *entryname)

+{

+    struct cache_req_data input = {0};

+

+    input.name.input = mapname;

+    input.autofs_entry_name = entryname;

+

+    return cache_req_data_create(mem_ctx, type, &input);

+}

+

 void

 cache_req_data_set_bypass_cache(struct cache_req_data *data,

                                 bool bypass_cache)

diff --git a/src/responder/common/cache_req/cache_req_plugin.h b/src/responder/common/cache_req/cache_req_plugin.h

index c040bf380..745a36c0e 100644

--- a/src/responder/common/cache_req/cache_req_plugin.h

+++ b/src/responder/common/cache_req/cache_req_plugin.h

@@ -316,5 +316,6 @@ extern const struct cache_req_plugin cache_req_netgroup_by_name;

 extern const struct cache_req_plugin cache_req_host_by_name;

 extern const struct cache_req_plugin cache_req_autofs_map_entries;

 extern const struct cache_req_plugin cache_req_autofs_map_by_name;

+extern const struct cache_req_plugin cache_req_autofs_entry_by_name;

 #endif /* _CACHE_REQ_PLUGIN_H_ */

diff --git a/src/responder/common/cache_req/cache_req_private.h b/src/responder/common/cache_req/cache_req_private.h

index a88c838d9..34bd3ce15 100644

--- a/src/responder/common/cache_req/cache_req_private.h

+++ b/src/responder/common/cache_req/cache_req_private.h

@@ -83,6 +83,7 @@ struct cache_req_data {

     const char *sid;

     const char *alias;

     const char **attrs;

+    const char *autofs_entry_name;

     struct {

         struct cache_req_parsed_name *name;

diff --git a/src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c b/src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c

new file mode 100644

index 000000000..17b0b508e

--- /dev/null

+++ b/src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c

@@ -0,0 +1,129 @@

+/*

+    Authors:

+        Pavel Březina <pbrezina@redhat.com>

+

+    Copyright (C) 2019 Red Hat

+

+    This program is free software; you can redistribute it and/or modify

+    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 <talloc.h>

+#include <ldb.h>

+

+#include "db/sysdb.h"

+#include "db/sysdb_autofs.h"

+#include "util/util.h"

+#include "providers/data_provider.h"

+#include "responder/common/cache_req/cache_req_plugin.h"

+

+static const char *

+cache_req_autofs_entry_by_name_create_debug_name(TALLOC_CTX *mem_ctx,

+                                                 struct cache_req_data *data,

+                                                 struct sss_domain_info *domain)

+{

+    return talloc_asprintf(mem_ctx, "%s:%s",

+                           data->name.name,

+                           data->autofs_entry_name);

+}

+

+static errno_t

+cache_req_autofs_entry_by_name_lookup(TALLOC_CTX *mem_ctx,

+                                      struct cache_req *cr,

+                                      struct cache_req_data *data,

+                                      struct sss_domain_info *domain,

+                                      struct ldb_result **_result)

+{

+    struct ldb_message *entry;

+    struct ldb_result *result;

+    errno_t ret;

+

+    ret = sysdb_get_autofsentry(mem_ctx, domain, data->name.name,

+                                data->autofs_entry_name, &entry);

+    if (ret != EOK) {

+        return ret;

+    }

+

+    result = cache_req_create_ldb_result_from_msg(mem_ctx, entry);

+    if (result == NULL) {

+        talloc_free(entry);

+        return ENOMEM;

+    }

+

+    *_result = talloc_steal(mem_ctx, result);

+    return EOK;

+}

+

+static struct tevent_req *

+cache_req_autofs_entry_by_name_dp_send(TALLOC_CTX *mem_ctx,

+                                       struct cache_req *cr,

+                                       struct cache_req_data *data,

+                                       struct sss_domain_info *domain,

+                                       struct ldb_result *result)

+{

+    return sss_dp_get_autofs_send(mem_ctx, cr->rctx, domain, true,

+                                  SSS_DP_AUTOFS, data->name.name);

+}

+

+const struct cache_req_plugin cache_req_autofs_entry_by_name = {

+    .name = "Get autofs entry",

+    .attr_expiration = SYSDB_CACHE_EXPIRE,

+    .parse_name = true,

+    .ignore_default_domain = true,

+    .bypass_cache = false,

+    .only_one_result = false,

+    .search_all_domains = false,

+    .require_enumeration = false,

+    .allow_missing_fqn = true,

+    .allow_switch_to_upn = false,

+    .upn_equivalent = CACHE_REQ_SENTINEL,

+    .get_next_domain_flags = 0,

+

+    .is_well_known_fn = NULL,

+    .prepare_domain_data_fn = NULL,

+    .create_debug_name_fn = cache_req_autofs_entry_by_name_create_debug_name,

+    .global_ncache_add_fn = NULL,

+    .ncache_check_fn = NULL,

+    .ncache_add_fn = NULL,

+    .ncache_filter_fn = NULL,

+    .lookup_fn = cache_req_autofs_entry_by_name_lookup,

+    .dp_send_fn = cache_req_autofs_entry_by_name_dp_send,

+    .dp_recv_fn = cache_req_common_dp_recv,

+    .dp_get_domain_check_fn = NULL,

+    .dp_get_domain_send_fn = NULL,

+    .dp_get_domain_recv_fn = NULL,

+};

+

+struct tevent_req *

+cache_req_autofs_entry_by_name_send(TALLOC_CTX *mem_ctx,

+                                    struct tevent_context *ev,

+                                    struct resp_ctx *rctx,

+                                    struct sss_nc_ctx *ncache,

+                                    int cache_refresh_percent,

+                                    const char *domain,

+                                    const char *mapname,

+                                    const char *entryname)

+{

+    struct cache_req_data *data;

+

+    data = cache_req_data_autofs_entry(mem_ctx, CACHE_REQ_AUTOFS_ENTRY_BY_NAME,

+                                       mapname, entryname);

+    if (data == NULL) {

+        return NULL;

+    }

+

+    return cache_req_steal_data_and_send(mem_ctx, ev, rctx, ncache,

+                                         cache_refresh_percent,

+                                         CACHE_REQ_POSIX_DOM, domain,

+                                         data);

+}

diff --git a/src/tests/cwrap/Makefile.am b/src/tests/cwrap/Makefile.am

index 3fbcebf3c..aaec6c700 100644

--- a/src/tests/cwrap/Makefile.am

+++ b/src/tests/cwrap/Makefile.am

@@ -66,6 +66,7 @@ SSSD_CACHE_REQ_OBJ = \

     ../../../src/responder/common/cache_req/plugins/cache_req_host_by_name.c \

     ../../../src/responder/common/cache_req/plugins/cache_req_autofs_map_entries.c \

     ../../../src/responder/common/cache_req/plugins/cache_req_autofs_map_by_name.c \

+    ../../../src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c \

     $(NULL)

 SSSD_RESPONDER_IFACE_OBJ = \

-- 

2.20.1