+ } else if (ret < 0)
+ send_va_buffer(fd, "%s\n", PARA_STRERROR(-ret));
+ return ret;
+}
+
+/**
+ * Flags used by the cpsi command.
+ *
+ * \sa com_cpsi().
+ */
+enum cpsi_flags {
+ /** Whether the lyrics id should be copied. */
+ CPSI_FLAG_COPY_LYRICS_ID = 1,
+ /** Whether the image id should be copied. */
+ CPSI_FLAG_COPY_IMAGE_ID = 2,
+ /** Whether the lastplayed time should be copied. */
+ CPSI_FLAG_COPY_LASTPLAYED = 4,
+ /** Whether the numplayed count should be copied. */
+ CPSI_FLAG_COPY_NUMPLAYED = 8,
+ /** Whether the attributes should be copied. */
+ CPSI_FLAG_COPY_ATTRIBUTES = 16,
+ /** Activates verbose mode. */
+ CPSI_FLAG_VERBOSE = 32,
+};
+
+struct cpsi_action_data {
+ unsigned flags;
+ unsigned num_copied;
+ struct para_buffer pb;
+ struct afs_info source_afsi;
+};
+
+static int copy_selector_info(__a_unused struct osl_table *table,
+ struct osl_row *row, const char *name, void *data)
+{
+ struct cpsi_action_data *cad = data;
+ struct osl_object target_afsi_obj;
+ int ret;
+ struct afs_info old_afsi, target_afsi;
+ struct afsi_change_event_data aced;
+
+ ret = get_afsi_object_of_row(row, &target_afsi_obj);
+ if (ret < 0)
+ return ret;
+ load_afsi(&target_afsi, &target_afsi_obj);
+ old_afsi = target_afsi;
+ if (cad->flags & CPSI_FLAG_COPY_LYRICS_ID)
+ target_afsi.lyrics_id = cad->source_afsi.lyrics_id;
+ if (cad->flags & CPSI_FLAG_COPY_IMAGE_ID)
+ target_afsi.image_id = cad->source_afsi.image_id;
+ if (cad->flags & CPSI_FLAG_COPY_LASTPLAYED)
+ target_afsi.last_played = cad->source_afsi.last_played;
+ if (cad->flags & CPSI_FLAG_COPY_NUMPLAYED)
+ target_afsi.num_played = cad->source_afsi.num_played;
+ if (cad->flags & CPSI_FLAG_COPY_ATTRIBUTES)
+ target_afsi.attributes = cad->source_afsi.attributes;
+ save_afsi(&target_afsi, &target_afsi_obj); /* in-place update */
+ cad->num_copied++;
+ if (cad->flags & CPSI_FLAG_VERBOSE)
+ para_printf(&cad->pb, "copied afsi to %s\n", name);
+ aced.aft_row = row;
+ aced.old_afsi = &old_afsi;
+ afs_event(AFSI_CHANGE, &cad->pb, &aced);
+ return 1;
+}
+
+static int com_cpsi_callback(const struct osl_object *query,
+ struct osl_object *result)
+{
+ struct cpsi_action_data cad = {.flags = *(unsigned *)query->data};
+ int ret;
+ char *source_path = (char *)query->data + sizeof(cad.flags);
+
+ ret = get_afsi_of_path(source_path, &cad.source_afsi);
+ if (ret < 0)
+ goto out;
+ struct pattern_match_data pmd = {
+ .table = audio_file_table,
+ .loop_col_num = AFTCOL_HASH,
+ .match_col_num = AFTCOL_PATH,
+ .patterns = {.data = source_path + strlen(source_path) + 1,
+ .size = query->size - sizeof(cad.flags)
+ - strlen(source_path) - 1},
+ .data = &cad,
+ .action = copy_selector_info
+ };
+ ret = for_each_matching_row(&pmd);
+out:
+ if (ret < 0)
+ para_printf(&cad.pb, "%s\n", PARA_STRERROR(-ret));
+ if (cad.flags & CPSI_FLAG_VERBOSE) {
+ if (cad.num_copied)
+ para_printf(&cad.pb, "copied requested afsi from %s "
+ "to %u files\n",
+ source_path, cad.num_copied);
+ else
+ para_printf(&cad.pb, "nothing copied\n");
+ }
+ if (cad.pb.buf) {
+ result->data = cad.pb.buf;
+ result->size = cad.pb.size;
+ return 1;
+ }
+ return ret < 0? ret : 0;
+}
+
+int com_cpsi(int fd, int argc, char * const * const argv)
+{
+ unsigned flags = 0;
+ int i, ret;
+ struct osl_object options = {.data = &flags, .size = sizeof(flags)},
+ result;
+
+ for (i = 1; i < argc; i++) {
+ const char *arg = argv[i];
+ if (arg[0] != '-')
+ break;
+ if (!strcmp(arg, "--")) {
+ i++;
+ break;
+ }
+ if (!strcmp(arg, "-y")) {
+ flags |= CPSI_FLAG_COPY_LYRICS_ID;
+ continue;
+ }
+ if (!strcmp(arg, "-i")) {
+ flags |= CPSI_FLAG_COPY_IMAGE_ID;
+ continue;
+ }
+ if (!strcmp(arg, "-l")) {
+ flags |= CPSI_FLAG_COPY_LASTPLAYED;
+ continue;
+ }
+ if (!strcmp(arg, "-n")) {
+ flags |= CPSI_FLAG_COPY_NUMPLAYED;
+ continue;
+ }
+ if (!strcmp(arg, "-a")) {
+ flags |= CPSI_FLAG_COPY_ATTRIBUTES;
+ continue;
+ }
+ if (!strcmp(arg, "-v")) {
+ flags |= CPSI_FLAG_VERBOSE;
+ continue;
+ }
+ break;
+ }
+ if (i + 1 >= argc) /* need at least souce file and pattern */
+ return -E_AFT_SYNTAX;
+ if (!(flags & ~CPSI_FLAG_VERBOSE)) /* no copy flags given */
+ flags = ~(unsigned)CPSI_FLAG_VERBOSE | flags;
+ ret = send_option_arg_callback_request(&options, argc - i, argv + i,
+ com_cpsi_callback, &result);
+ if (ret > 0) {
+ send_buffer(fd, (char *)result.data);
+ free(result.data);
projects / paraslash.git / blobdiff