Subversion Repositories mdb

/*

 * Copyright (C) 2015 by Andreas Theofilu <andreas@theosys.at>

 *

 * All rights reserved. No warranty, explicit or implicit, provided.

 *

 * NOTICE:  All information contained herein is, and remains

 * the property of Andreas Theofilu and his suppliers, if any.

 * The intellectual and technical concepts contained

 * herein are proprietary to Andreas Theofilu and its suppliers and

 * may be covered by European and Foreign Patents, patents in process,

 * and are protected by trade secret or copyright law.

 * Dissemination of this information or reproduction of this material

 * is strictly forbidden unless prior written permission is obtained

 * from Andreas Theofilu.

 */

#include <stdio.h>

#include <string.h>

#include <strings.h>

#include <unistd.h>

#include <stdlib.h>

#include <ctype.h>

#include <math.h>

#include <syslog.h>

#include <errno.h>

#include <sys/stat.h>

#include <sys/types.h>

#include <fcntl.h>

#include <sqlite3.h>

#include "config.h"

#include "helplib.h"

#include "user.h"

#include "play.h"

int deleteQueue(int s1, int id)

{

	char fname[256], tmpname[256], hv0[256], buffer[8192];

	int fd, tmpfd;

	strcpy(fname, configs.home);

	strcat(fname, NOWPLAY);

	strcpy(tmpname, configs.home);

	strcat(tmpname, "/newqueue");

	/* If the id is less than 0, we delete the whole queue. If the audio is

	 * playing, it is stopped before. */

	if (id < 0)

	{

		if (playerActive)

			nextCommand = PLAY_STOP_NOW;

		unlink(fname);

		freeQueue();

		return TRUE;

	}

	if ((fd = open(fname, O_RDWR | O_CREAT, S_IRUSR | S_IWUSR | S_IRGRP)) <= 0)

	{

		syslog(LOG_WARNING, "Error opening file %s: %s", fname, strerror(errno));

		sprintf(hv0, "ERROR:DELETE:Error opening queue");

		write(s1, hv0, strlen(hv0));

		return FALSE;

	}

	if ((tmpfd = open(tmpname, O_RDWR | O_TRUNC | O_CREAT | O_EXCL, S_IRUSR | S_IWUSR)) <= 0)

	{

		syslog(LOG_WARNING, "Error creating a temporary file: %s", strerror(errno));

		close(fd);

		sprintf(hv0, "ERROR:DELETE:Error creating a temporary file");

		write(s1, hv0, strlen(hv0));

		return FALSE;

	}

	while (readLine(fd, &buffer[0], sizeof(buffer)) != NULL)

	{

		char *t, *buf;

		char path[512], id3_title[256], id3_artist[256], id3_album[256], id3_genre[256];

		int x, type, pid;

		memset(path, 0, sizeof(path));

		memset(id3_title, 0, sizeof(id3_title));

		memset(id3_artist, 0, sizeof(id3_artist));

		memset(id3_album, 0, sizeof(id3_album));

		memset(id3_genre, 0, sizeof(id3_genre));

		if ((buf = strdup(buffer)) == NULL)

		{

			syslog(LOG_DAEMON, "Error duplicating a string: %s", strerror(errno));

			close(fd);

			close(tmpfd);

			return FALSE;

		}

		x = 0;

		t = strtok(buffer, "\t");

		while (t)

		{

			switch(x)

			{

				case 0: strncpy(path, t, sizeof(path)-1); break;

				case 1: type = atoi(t); break;

				case 2: pid = atoi(t); break;

				case 3: strncpy(id3_title, t, sizeof(id3_title) - 1); break;

				case 4: strncpy(id3_artist, t, sizeof(id3_artist) - 1); break;

				case 5: strncpy(id3_album, t, sizeof(id3_album) - 1); break;

				case 6: strncpy(id3_genre, t, sizeof(id3_genre) - 1); break;

			}

			x++;

			t = strtok(NULL, "\t");

		}

		if (id == pid)

		{

			free (buf);

			continue;

		}

		/* Write the content into the temporary file */

		write (tmpfd, buf, strlen(buf));

		strcpy (hv0, "\n");

		write (tmpfd, hv0, strlen(hv0));

		free (buf);

	}

	close (fd);

	unlink(fname);

	rename(tmpname, fname);

	readQueue();

	return TRUE;

}

/*

 * This function deletes a whole playlist from a user. The id is the id of the

 * playlist in database table USERS.

 */

int deletePlaylist(int s1, int id)

{

	char query[1024];

	char fname[256];

	sqlite3 *db;

	char *zErrMsg = 0;

	int rc;

	if (id < 0)

		return FALSE;

	strcpy(fname, configs.home);

	strcat(fname, MUSICDB);

	rc = sqlite3_open(fname, &db);

	if (rc)

	{

		syslog(LOG_WARNING, "Error opening database %s: %s", fname, sqlite3_errmsg(db));

		strcpy(query, "ERROR:DELETE:Error opening database;");

		write (s1, query, strlen(query));

		return FALSE;

	}

	sprintf(query, "delete from playlists where userid = %d;delete from users where id = %d;", id, id);

	if ((rc = sqlite3_exec(db, query, NULL, NULL, &zErrMsg)) != SQLITE_OK)

	{

		syslog(LOG_WARNING, "SQL error [%s]: %s", query, zErrMsg);

		sqlite3_free(zErrMsg);

		sqlite3_close(db);

		return FALSE;

	}

	sqlite3_close(db);

	scanUser(s1, userchain->uname);

	return TRUE;

}

int deletePlaylistEntry(int s1, int id)

{

	char query[1024];

	char fname[256];

	sqlite3 *db;

	char *zErrMsg = 0;

	int rc;

	if (id < 0)

		return FALSE;

	strcpy(fname, configs.home);

	strcat(fname, MUSICDB);

	rc = sqlite3_open(fname, &db);

	if (rc)

	{

		syslog(LOG_WARNING, "Error opening database %s: %s", fname, sqlite3_errmsg(db));

		strcpy(query, "ERROR:DELETE:Error opening database;");

		write (s1, query, strlen(query));

		return FALSE;

	}

	sprintf(query, "delete from playlists where id = %d", id);

	if ((rc = sqlite3_exec(db, query, NULL, NULL, &zErrMsg)) != SQLITE_OK)

	{

		syslog(LOG_WARNING, "SQL error [%s]: %s", query, zErrMsg);

		sqlite3_free(zErrMsg);

		sqlite3_close(db);

		return FALSE;

	}

	sqlite3_close(db);

	return TRUE;

}